3

豚を介してデータをロードし、HBase に処理します。HDFS にテキスト ファイルをロードしました。次に、豚で以下のコマンドを使用しました。

A = LOAD '/tmp/hive-Vijay.Shinde/file.txt' USING PigStorage(',')
 as (strdata1:chararray, strdata2:int);

それから私は使用しました、

STORE A INTO 'mydata' USING org.apache.pig.backend.hadoop.hbase.HBaseStorage('mycf:strdata2');

mydata は HBase のテーブルです。

エラーが発生します：Unhandled internal error

4

2 に答える 2

1
  1. pig ファイルに hbase jar を登録してみてください。例えば。登録 /home/hadoop/lib/hbase-0.92.0.jar
  2. データを挿入する前に、列ファミリーを持つ hbase テーブルを作成したことを確認してください。
  3. また、hadoop、pig、および hbase のバージョンについても言及してください。

  4. また、Web インターフェイスでデバッグ ログを確認することもできます。クラスタをローカルで実行している場合は、localhost/jobtracker.jsp を使用します

    これにより、ジョブに関するより有用なログ情報が得られます。

于 2013-10-18T15:43:29.977 に答える
0

このステートメントは機能する可能性があります。

STORE A into 'hbase://table_name' USING org.apache.pig.backend.hadoop.hbase.HBaseStorage('cf1:*');
于 2014-06-09T11:45:25.977 に答える