我试图做增量导入最初使用以下命令。
sqoop导入--连接jdbc:oracle:thin:@orau20:1555:--用户名x--密码x--表emp--以“\001”结尾的字段--以“\”转义--输入空字符串“\n”--输入空非字符串“\n”--目标目录/user//test/emp--增量追加--检查列dttm\u stamp\u sec-m 1
在这里我发现一些记录丢失,其中dttm\u stamp\u sec是空记录。此列有一些空记录,这些记录不是从oracle导入到hadoop的。感谢您的帮助。
1条答案
按热度按时间3gtaxfhh1#
我们应该指定--check列,它总是有一个init值