Я пытаюсь выполнить инкрементное последнее изменение с помощью sqoop
sqoop job --create IncrementalImport \
-- import \
--connect 'jdbc:sqlserver://servername;username=xxxxx;password=xxxx;database=xxxx' \
--driver "com.microsoft.sqlserver.jdbc.SQLServerDriver" \
--table table_name \
--target-dir /dir_name \
--incremental lastmodified \
--check-column date \
--merge-key primary_key_column \
-m 1
У меня возникает проблема при выполнении задания sqoop --exec IncrementalImport
Предупреждение: / usr /hdp / 2.6.5.0-292 / могущество не существует!Импорт Accumulo потерпит неудачу.Пожалуйста, установите $ ACCUMULO_HOME в корневой каталог вашей установки Accumulo.Подобрал JAVA_TOOL_OPTIONS: -Xmx1024m -Djava.io.tmpdir = / h / tmp 18/10/24 08:27:40 INFO sqoop.Sqoop: Запуск версии Sqoop: 1.4.6.2.6.5.0-292 ssound13 @ hpchdd2e: ~> Задание sqoop --exec IncrementalImportLastModified Предупреждение: /usr/hdp/2.6.5.0-292/accumulo не существует!Импорт Accumulo потерпит неудачу.Пожалуйста, установите $ ACCUMULO_HOME в корневой каталог вашей установки Accumulo.Подобрал JAVA_TOOL_OPTIONS: -Xmx1024m -Djava.io.tmpdir = / h / tmp 18/10/24 08:27:57 INFO sqoop.Sqoop: Запуск версии Sqoop: 1.4.6.2.6.5.0-292 18/10/2408:27:58 ПРЕДУПРЕЖДЕНИЕ sqoop.ConnFactory: Параметр --driver установлен в явный драйвер, однако соответствующий менеджер соединений не устанавливается (через --connection-manager).Sqoop собирается вернуться к org.apache.sqoop.manager.GenericJdbcManager.Пожалуйста, укажите явно, какой менеджер соединений следует использовать в следующий раз.18/10/24 08:27:58 INFO manager.SqlManager: использование по умолчанию fetchSize 1000. 18/10/24 08:27:58 INFO tool.CodeGenTool: начало генерации кода 18/10/24 08:27:59 INFO manager.SqlManager: Выполнение оператора SQL: SELECT t. * FROM table_name AS t WHERE 1 = 0 18/10/24 08:27:59 INFO manager.SqlManager: Выполнение оператора SQL: SELECT t. * FROM table_name AS t WHERE 1 = 018/10/24 08:27:59 ИНФОРМАЦИЯ orm.CompilationManager: HADOOP_MAPRED_HOME is /usr/hdp/2.6.5.0-292/hadoop-mapreduce Примечание: /tmp/sqoop-ssound13/compile/48dc5192c1b8869fb61635daava.table.a3 имя_сайта_3устаревший API.Примечание: Перекомпилируйте с -Xlint: не рекомендуется для деталей.18/10/24 08:28:00 INFO orm.CompilationManager: Запись файла jar: /tmp/sqoop-ssound13/compile/48dc5192c1b8869fb61635da887c3aa0/Attrib_Type.jar 18/10/24 08:28:01 INFO manager.SqlMagerоператор: SELECT t. * FROM table_name AS t WHERE 1 = 0 18/10/24 08:28:01 ОШИБКА manager.SqlManager: исключение SQL для доступа к текущей отметке времени: com.microsoft.sqlserver.jdbc.SQLServerException: неправильный синтаксис рядом с ')».com.microsoft.sqlserver.jdbc.SQLServerException: неправильный синтаксис рядом с ')'.по адресу com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDatabaseError (SQLServerException.java:216) по адресу com.microsoft.sqlserver.jdbc.SQLServerStatement.getNextResult (SQLServerStatement.java:1515) в com.mser.SersoftState(SQLServerStatement.java:792) в com.microsoft.sqlserver.jdbc.SQLServerStatement $ StmtExecCmd.doExecute (SQLServerStatement.java:689) в com.microsoft.sqlserver.jdbc.TDSCommand.execute (IOBuffer).microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand (SQLServerConnection.java:1715) в com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand (SQLServerStatement.java:180) в com.microsoft.sqmentServerStateServer.jerStateServer.jerStateServer.jerStateServer.jsserver.jsJava: 155) в com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery (SQLServerStatement.java:616) в org.apache.sqoop.manager.SqlManager.getCurrentDbTimestamp (SqlManager.java:98ap.soop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.oop.я. org в org.ImportTool.initIncrementalConstraints (ImportTool.java:328) в org.apache.sqoop.tool.ImportTool.importTable (ImportTool.java:498) в org.apache.sqoop.tool.ImportTool.run (ImportTool.java:615) в org.apache.sqoop.tool.JobTool.execJob (JobTool.java:243) в org.apache.sqoop.tool.JobTool.run (JobTool.java:298) в org.apache.sqoop.Sqoop.run (Sqoop.java:147) вorg.apache.hadoop.util.ToolRunner.run (ToolRunner.java:76) в org.apache.sqoop.Sqoop.runSqoop (Sqoop.java:183) в org.apache.sqoop.Sqoop.runTool (Sqoop.java:225) в org.apache.sqoop.Sqoop.runTool (Sqoop.java:234) вorg.apache.sqoop.Sqoop.main (Sqoop.java:243) 18/10/24 08:28:01 ОШИБКА tool.ImportTool: Обнаружено IOException при выполнении задания на импорт: java.io.IOException: Не удалось получить текущее время из базы данныхв org.apache.sqoop.tool.ImportTool.initIncrementalConstraints (ImportTool.java:330) в org.apache.sqoop.tool.ImportTool.importTable (ImportTool.java:498) в org.apache.sqoop.tool.ImpunTool.(ImportTool.java:615) в org.apache.sqoop.tool.JobTool.execJob (JobTool.java:243) в org.apache.sqoop.tool.JobTool.run (JobTool.java:298) в org.apache.sqoop.Sqoop.run (Sqoop.java:147) в org.apache.hadoop.util.ToolRunner.run (ToolRunner.java:76) в org.apache.sqoop.Sqoop.runSqoop (Sqoop.java:183) в org.apache.sqoop.Sqoop.runTool (Sqoop.java:225) в org.apache.sqoop.Sqoop.runTool (Sqoop.java:234) в org.apache.sqoop.Sqoop.main (Sqoop.java:243)
Может кто-нибудь помочь, пожалуйста, зарегистрируйте вопрос
На сервере sql последний измененный столбец имеет тип данных datetime - гггг-мм-дд 00: 00: 000.0000