Sqoop 증분 가져 오기 (db 스키마가 잘못됨)

Question

Sanbox 2.1 및 Microsoft SQL Server (AdventureWorks 데이터베이스)를 사용하여 증분 가져 오기를 시도하고 있습니다. 증분 가져 오기 위해 난 다음 명령을 사용하고 있습니다 : "(. SalesLT] [ProductModelID]) MAX를 선택 ProductModel FROM"아래의 오류 메시지에서 볼 수 있듯이

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 

는, SELECT 문을 구축되지 않는 옳은 길.

스키마 이름은 ... 테이블 이름과 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'. 

어떤 도움에 감사드립니다.

감사합니다.

추신. 전체 테이블을 가져 오는 것이 좋습니다.

sqoop import --connect "jdbc:sqlserver://192.168.40.133:1434;database=AdventureWorksLT2012;username=test;password=test" --table ProductModel --hive-import -- --schema SalesLT 

Answer 1

이 시도 : 나는 명령이 작동합니다 다음과 같은 생각

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" 

Answer 2

을 ..

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