我正在尝试使用水槽将日志流式传输到 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 状态。