我正在尝试使用增量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小时,因此我会丢失一些记录。
似乎最后一个值采用服务器时区值,而不是数据库中的最后一个记录值。
谢谢你的帮助!
1条答案
按热度按时间5sxhfpxr1#
尝试将usetimezone选项添加到连接字符串中