0

我正在尝试使用水槽将日志流式传输到 hbase。我有一个正在运行的分布式水槽设置和一个 hbase 集群;两者都使用相同的 Zookeeper。Flume 正在使用各种命令(文本、尾部、自定义接收器过滤器),但是当我尝试在 Flume shell 或 Web UI 中使用以下命令时:

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

该命令在命令行和 Web UI 中都永远处于 EXECING 状态。

4

1 回答 1

0

您需要在您的水槽库或类路径中有 hbase-xyzjar 文件。

您还需要在安装水槽时进行 hbase 配置,例如将 hbase-site.xml 复制到 $flume_home/conf 目录。

于 2012-05-21T05:22:04.703 回答