flume

command line flume throws an error

I want to collect logs from the console with flume, I start flume with the following command: process_which_generates_the_log | flume node_nowatch -1 -n node -c 'node : console | agentBESink("localhost", 12345)' but it says: 10/09/22 13:59:21 INFO agent.FlumeNode: Loading spec from command line: 'node : console | agentBESink("loca...

Writing a custom Flume decorator, but getting errors. What am I missing?

I'm writing a custom decorator plugin for Cloudera's distributed log aggregation system, Flume. My Java code is below: package multiplex; import java.io.IOException; import java.util.ArrayList; import java.util.List; import com.cloudera.flume.conf.Context; import com.cloudera.flume.conf.SinkFactory.SinkDecoBuilder; import com.cloudera...