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

Question

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

下面是命令和错误堆栈：

./dse sqoop cql-import --table USERS --columns 名字 --cassandra-keyspace ORCL --cassandra-table 用户 --connect jdbc:oracle:thin:scott/xxxx@//us01u245:1521/orcldb --cassandra-host us01u246

ERROR 01:04:27 运行导入作业时遇到 IOException： java.io.IOException：读取表元数据失败 在 com.datastax.bdp.sqoop.SqoopUtil.setCqlImportOptions(SqoopUtil.java:219) 在 com.datastax.bdp.sqoop.CqlImportJob.configureOutputFormat(CqlImportJob.java:79) 在 org.apache.sqoop.mapreduce.ImportJobBase.runImport（ImportJobBase.java:240） 在 com.datastax.bdp.sqoop.SqlManagerAdapter.importTable(SqlManagerAdapter.java:236) 在 org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:497) 在 org.apache.sqoop.tool.ImportTool.run(ImportTool.java:601) 在 org.apache.sqoop.Sqoop.run(Sqoop.java:143) 在 org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65) 在 org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:179) 在 org.apache.sqoop.Sqoop.runTool(Sqoop.java:218) 在 org.apache.sqoop.Sqoop.runTool(Sqoop.java:227) 在 org.apache.sqoop.Sqoop.main(Sqoop.java:236) 在 com.cloudera.sqoop.Sqoop.main(Sqoop.java:57) 引起：java.io.IOException：没有为 ORCL.USERS 找到表元数据 在 com.datastax.bdp.sqoop.SqoopUtil.setCqlImportOptions(SqoopUtil.java:161)

Answer 1

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