Sqoop增量导入(数据库模式不正确)

蠕变

我试图使用Sanbox 2.1和Microsoft SQL Server(AdventureWorks数据库)进行增量导入。对于增量导入,我使用以下命令:

sqoop import --connect "jdbc:sqlserver://192.168.40.133:1434;database=AdventureWorksLT2012;username=test;password=test" --table ProductModel --hive-import --check-column ProductModelID --incremental append --last-value 128 -- --schema SalesLT

如您在下面的错误消息中所看到的,选择语句“从ProductModel提取SELECT MAX([SalesLT]。[ProductModelID])”的方法不正确。

模式名称将添加到没有表名称的列中,并且FROM子句中的表名称缺少模式名称…

Warning: /usr/lib/sqoop/../accumulo does not exist! Accumulo imports will fail.
Please set $ACCUMULO_HOME to the root of your Accumulo installation.
14/06/24 07:05:33 INFO sqoop.Sqoop: Running Sqoop version: 1.4.4.2.1.1.0-385
14/06/24 07:05:33 INFO tool.BaseSqoopTool: Using Hive-specific delimiters for output. You can override
14/06/24 07:05:33 INFO tool.BaseSqoopTool: delimiters with --fields-terminated-by, etc.
14/06/24 07:05:33 INFO manager.SqlManager: Using default fetchSize of 1000
14/06/24 07:05:33 INFO manager.SQLServerManager: We will use schema SalesLT
14/06/24 07:05:33 INFO tool.CodeGenTool: Beginning code generation
14/06/24 07:05:34 INFO manager.SqlManager: Executing SQL statement: SELECT t.* FROM [SalesLT].[ProductModel] AS t WHERE 1=0
14/06/24 07:05:34 INFO orm.CompilationManager: HADOOP_MAPRED_HOME is /usr/lib/hadoop-mapreduce
Note: /tmp/sqoop-root/compile/bcb9143989664ced51458e8a0dbd52b9/ProductModel.java uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
14/06/24 07:05:37 INFO orm.CompilationManager: Writing jar file: /tmp/sqoop-root/compile/bcb9143989664ced51458e8a0dbd52b9/ProductModel.jar
14/06/24 07:05:37 INFO tool.ImportTool: Maximal id query for free form incremental import: SELECT MAX([SalesLT].[ProductModelID]) FROM ProductModel
14/06/24 07:05:37 ERROR tool.ImportTool: Encountered IOException running import job: java.io.IOException: com.microsoft.sqlserver.jdbc.SQLServerException: Invalid object name 'ProductModel'.

任何帮助表示赞赏。

谢谢!

PS。导入完整表工作正常。

sqoop import --connect "jdbc:sqlserver://192.168.40.133:1434;database=AdventureWorksLT2012;username=test;password=test" --table ProductModel --hive-import -- --schema SalesLT
苏雷什·拉姆(Suresh Ram)

试试这个 :

sqoop import --connect "jdbc:sqlserver://192.168.40.133:1434;database=AdventureWorksLT2012;username=test;password=test" --table ProductModel --hive-import -- --schema SalesLT --incremental append --check-column ProductModelID --last-value "128"

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

不正确的数据插入数据库

来自数据库的数据不正确

恢复SQL数据库-'-'附近的语法不正确

保存到数据库的值不正确

数据库方法语法不正确

来自数据库的错误结果显示不正确

MS Access数据库是/否更新不正确

关系数据库显示不正确

从数据库检索的HTML似乎不正确

数据库查询返回不正确的行

SQOOP增量导入:当从数据库中删除一行时,它如何处理数据?

DataReader返回不正确的.net数据类型的数据库表浮点列

Rocket UNIVERSE数据库中带有查询的“数据类型不正确”

Laravel:来自数据库的消息的日期显示不正确

如果密码不正确,登录尝试存入数据库

数据库产生外键结果不正确的问题

NLog似乎在数据库中写入了不正确的值

将数据库导出为脚本;序列设置不正确

Laravel:如果请求规则不正确,请登录数据库

SQL错误-关键字“数据库”附近的语法不正确

无法连接:不正确的登录参数-没有数据库的Crystal Reports

Hibernate数据库连接自动限定用户名不正确

数据库设置不正确,IList上的值为空

错误:不正确的整数值:将表(.csv 文件)插入 MariaDB/MySQL 数据库

评论已保存到数据库,但显示不正确

尝试插入SQL Server数据库时'PK'错误附近的语法不正确

Laravel Vue使用v-for指令从数据库表结果显示不正确

在数据库中插入了不正确的值

更新数据库中的记录时'('附近的语法不正确