将数据从sql server导入hbase,使用sqoop从sql检索到395809条记录,但hbase中只有365587行。
我使用的import命令是
sqoop import --hbase-table test --hbase-row-key conversation_id --column-family cf1 --columns conversation_id,app_id --connect "jdbc:sqlserver://******;database=*******;username=test;password=*******" --table test -m 1
我用来创建hbase表的命令是
create 'test',{NAME=>'cf1',BLOCKCACHE=> false,BLOCKSIZE=>1073741824}
我怎样才能解决这个问题?
谢谢,
mqi公司
1条答案
按热度按时间vkc1a9a21#
很难说,但机会是有限的
conversation_id
不是唯一的。有关此主题的更多交互式帮助,请尝试使用sqoop邮件列表。