Я пытаюсь использовать flume для потоковой передачи журналов в hbase.У меня работает распределенная установка flume и кластер hbase;оба используют один и тот же Zookeeper.Flume работает с различными командами (текст, хвост, настраиваемый фильтр приемника), но когда я пытаюсь использовать следующее в оболочке Flume или в веб-интерфейсе:
exec config <node> 'tail("<sample file>")' '{ customDecorator => hbase("<table>","<row key>", "<col family>", "<col name>", "<col value>") }'
Команда всегда находится в состоянии EXECING длякомандной строки и в веб-интерфейсе.