2017-04-26 6 views
0

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

答えて

0

列名が、データベースに小文字されている場合は、あなたがこのようなコマンドラインで小文字の名前を使用する必要があります--hbase-row-key "mid,eid..."

関連する問題