Sqoop工作增量上次更改错误的时间戳值

Question

我想创建一个Sqoop工作使用增量上次更改

sqoop job --create job_import_test8_by_query_update -- import \ 
--bindir ./ --connect 'jdbc:mysql://localhost/db?serverTimezone=UTC&useSSL=false' \ 
--username user \ 
--password pass \ 
--table test8 -m 2 \ 
--incremental lastmodified \ 
--check-column "timestamp_field" \ 
--last-value 0 \ 
--split-by "id" \ 
--merge-key "id" \ 
--verbose \ 
--target-dir /usr/local/sqlImport/1 

在这个例子中我有最后一个值问题

。 当最后一个值为“0”时第一次运行正常。然后最后一个值自动设置为current_local_time + 4小时，所以我正在失去一些记录。

看来，最后一个值取服务器时区值而不是数据库中的最后一个记录值。

感谢您的帮助！

Answer 1

尝试添加useTimezone选项连接字符串

--connect 'jdbc:mysql://localhost/db?useTimezone=true&serverTimezone=UTC'