0

flumeを使用してログをhbaseにストリーミングしようとしています。分散フルームセットアップとhbaseクラスターを実行しています。どちらも同じZookeeperを使用しています。Flumeはさまざまなコマンド(テキスト、テール、カスタムシンクフィルター)を使用していますが、FlumeシェルまたはWebUIで次のコマンドを使用しようとすると次のようになります。

exec config <node> 'tail("<sample file>")' '{ customDecorator => hbase("<table>","<row key>", "<col family>", "<col name>", "<col value>") }'

コマンドは、コマンドラインとWebUIの両方で永久にEXECING状態になります。

4

1 に答える 1

0

Flume ライブラリまたはクラスパスに hbase-xyzjar ファイルが必要です。

また、hbase-site.xml を $flume_home/conf ディレクトリにコピーするなど、flume インストールで hbase 構成が必要になります。

ベン

于 2012-05-21T05:22:04.703 に答える