2012-02-08 5 views
0

flumeを使用してhbaseにログをストリーミングしようとしています。分散フルエセットアップが実行されており、hbaseクラスタがあります。どちらも同じ飼い主を使用しています。水路は、様々なコマンド(テキスト、尾、カスタムシンクフィルタ)が、私は試してみて、使用時に水路シェルまたはWeb UIで、次のと協力しています。コマンドは、コマンドライン上で永遠の両方EXECING状態にあるhbaseシンク(Cloudera)を使用している場合、Flume "config"コマンドはEXECING状態のままです

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

Web UIに表示されます。

答えて

0

flumeのlibまたはclasspathにhbase-x.y.z.jarファイルが必要です。

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

ベン

関連する問題