当前位置: 首页 > 知识库问答 >
问题:

使用./dse sqoop cql-import将数据从oracle迁移到cassandra时出错

卫宁
2023-03-14

我在使用DSE SQOOP将oracle数据迁移到cassandra时出现以下错误。

下面是命令和错误堆栈:

。/DSE sq OOP cql-import-table USERS-columns first name-Cassandra-key space ORCL-Cassandra-table USERS-connect JDBC:Oracle:thin:Scott/xxxx @//us01u 245:1521/orc ldb-Cassandra-host us01u 246

错误01:04:27运行导入作业java.io时遇到IOException。IOException:无法读取位于com.datastax.bdp.sqoop.sqoop.sqlImportJob.configureOutputFormat(CqlImportJob.java:79)的com.datatax.bdp.sqoop.mapreduce.ImportJob Base.runImport(ImportJob-Base.java:240)的表元数据org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:497),位于org.apacher.sqoop.tool.ImportTool.run(ImortTool.java:601),位于.org.apache.hadoop.sqoop.run(sqoop.java:143),位于org.apache.hadoop.util.ToolRunner.run java:218),网址为org.apache.sqoop.sqoop.runTool(sqoop.java:227)com.cloudera.sqoop.sqoop.main(sqoop.java:236)上的org.apache.sqoop.main(Sqop.java:57)原因:java.io。IOException:找不到ORCL的表元数据。com.datastax.bdp.sqoop.SqoopUtil.setCqlImportOptions上的用户(sqoop Util.java:161)

共有1个答案

松刚豪
2023-03-14

表名之前可能缺少Oracle架构名。还要检查oracle表列和cassandra表列。它们区分大小写。

 类似资料:
  • 我正在构建一个Django应用程序,它有几个应用程序。使用SQLite数据库作为后端运行良好。当我试图使用“manage.py migrate”将后端迁移到Oracle时,我发现了以下错误 django.db.utils.DatabaseError:ORA-01950:对表空间“XXXXXX”没有权限 当我在数据库中检查我的用户权限时,它有创建表、视图等的权限。我尝试执行“manage.py sq

  • 问题内容: 我们的Oracle数据库遇到了严重的性能问题,我们想尝试将其迁移到基于MySQL的数据库(直接使用MySQL,或者最好是Infobright)。 问题是,在我们实际上不知道新数据库的所有功能是否符合我们的需求之前,我们需要让旧系统和新系统至少重叠数周(如果不是几个月)。 因此,这是我们的情况: Oracle数据库由多个表组成,每百万行。白天,实际上有成千上万的语句,我们无法停止迁移。

  • 问题内容: 将Solr核心迁移到elasticsearch索引的最佳方法是什么? 不推荐使用solr-river-plugin(https://github.com/javanna/elasticsearch-river- solr )。 问题答案: OpenSource Connections中有一个不错的,由爱心人士精心制作的自定义Python工具,您可以用来执行以下操作: https://g

  • 问题内容: 我有一个现有的PHP / MySQL应用程序,我正尝试将其迁移到AngularJS / Firebase,以作为学习这些较新技术的一种方式。 该应用程序在MySQL中具有自己的表架构。一个这样的表如下所示: 我的问题是:如何将这个表结构及其中的数据从MySQL迁移到Firebase? 我尝试通过查询将数据导出到JSON字符串中,例如: 这给出了有效的JSON字符串,例如: 我将其保存在

  • 我正在将我的java应用程序从Oracle JDK迁移到AdoptopenJDK,那么迁移到AdoptopenJDK需要做哪些更改。

  • 我正在尝试使用Kafka将数据从oracle迁移到mongodb。我取了一个1000万的样本记录集,列长为90,每行为5KB 我将数据分成10个线程,但其中一个线程不是每次都在运行....当我检查数据时,我看到MongoDB中丢失了100万条记录。 主类: Kafka制作人线程类: JSONObject obj=new JSONObject(); while(rs.next()){ 消费者类: