Oracleからsqoopジョブを使用してOracleからHbaseにデータを移行しようとしています。インポートに成功しましたが、インポート中にエラーがスローされますHbaseでも同じです。Sqoop2 Hbaseインポート:行キー列にnull値の行を挿入できませんでした
ジョブ1: :IDは、Oracleの主キーであるが、私は私のHBaseの行キーはMID_EID_RTIMESTAMP
地図還元エラーを投げることによって失敗したようにしたい
`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
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のもう一つの仕事をHBaseのインポートで作業されていません。 JOB2:
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