sqoop作业增量lastmanaged错误的时间戳值

emeijp43  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(327)

我正在尝试使用增量lastmodified创建一个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”时运行第一次可以正常工作。最后一个值会自动设置为当前\u本地\u时间+4小时,因此我会丢失一些记录。
似乎最后一个值采用服务器时区值,而不是数据库中的最后一个记录值。
谢谢你的帮助!

5sxhfpxr

5sxhfpxr1#

尝试将usetimezone选项添加到连接字符串中

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

相关问题