我正在尝试使用sqoop job将数据从oracle迁移到Hbase，看起来已经成功导出，但是在Hbase中导入相同数据时却抛出错误。
职位1:
`sqoop import --verbose --connect *** --username *** --password *** --table 'abc' --columns "MID,EID,RTIMESTAMP,VALUE,UTIMESTAMP" --split-by 'abc.ID' --hbase-table "HPVSQOOP" --column-family "cf1" --hbase-row-key MID,EID,RTIMESTAMP --num-mappers 4 --hbase-bulkload
其中ID是Oracle中的主键，但我希望我的HBase行键为MID_EID_RTIMESTAMP
Map-Reduced因抛出错误而失败:
INFO mapreduce.Job: Task Id : attempt_1492489711789_0014_m_000003_2, Status : FAILED Error: java.io.IOException: Could not insert row with null value for row-key column: MID,EID,RTIMESTAMP at org.apache.sqoop.hbase.ToStringPutTransformer.getPutCommand(ToStringPutTransformer.java:146) at org.apache.sqoop.mapreduce.HBaseBulkImportMapper.map(HBaseBulkImportMapper.java:83)
使用--query的另一个Job不适用于Hbase导入。
工作2:
sqoop import --verbose --connect *** --username *** --password **' --query "select MID,EID,VALUE,RTIMESTAMP,UTIMESTAMP,ID from database.abc where \$CONDITIONS" --split-by 'abc.ID' --hbase-table "HPVSQOOP" --column-family "cf1" --hbase-row-key "MID,EID,RTIMESTAMP" --num-mappers 4 --hbase-bulkload
最终抛出一个错误:
ERROR sqoop.Sqoop: Got exception running Sqoop: java.lang.NullPointerException java.lang.NullPointerException
最佳答案
如果列名称在数据库中为小写，则应在命令行中使用小写名称，例如--hbase-row-key "mid,eid..."
关于hadoop - Sqoop2 Hbase导入:无法为行键列插入具有空值的行，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/43635153/