Veerendra Nath Jasthi created FLUME-2836:
--------------------------------------------
Summary: Flume and Cassandra sink
Key: FLUME-2836
URL: https://issues.apache.org/jira/browse/FLUME-2836
Project: Flume
Issue Type: Bug
Components: Sinks+Sources
Affects Versions: v1.6.0
Environment: Ubuntu.14.04,hadoop.2.2.0,flume.1.6.0,cassandra.2.1.11,
Reporter: Veerendra Nath Jasthi
Fix For: notrack
This is My flume.conf file:
# custom Cassandra sink
cassandra_agent.sinks.sink3.type = com.veeru.flume.CustomCassandraSink
cassandra_agent.sinks.sink3.channel = channel1
cassandra_agent.sources = source1 source2 source3
cassandra_agent.channels = channel1 channel2 channel3
cassandra_agent.sinks = sink1 sink2 sink3
cassandra_agent.sources.source1.type = exec
cassandra_agent.sources.source1.command = tail -F /home/hduser/input1.log
cassandra_agent.sources.source1.channels = channel1
cassandra_agent.channels.channel1.type = memory
cassandra_agent.sinks.sink1.type = avro
cassandra_agent.sinks.sink1.hostname = localhost
cassandra_agent.sinks.sink1.port = 9160
cassandra_agent.sinks.sink1.channel = channel1
cassandra_agent.sources.source2.type = exec
cassandra_agent.sources.source2.command = tail -F /home/hduser/input2.log
cassandra_agent.sources.source2.channels = channel2
cassandra_agent.channels.channel2.type = memory
cassandra_agent.sinks.sink2.type = avro
cassandra_agent.sinks.sink2.hostname = localhost
cassandra_agent.sinks.sink2.port = 9160
cassandra_agent.sinks.sink2.channel = channel2
cassandra_agent.sources.source3.type = avro
cassandra_agent.sources.source3.bind = localhost
cassandra_agent.sources.source3.port = 9160
cassandra_agent.sources.source3.channels = channel3
cassandra_agent.channels.channel3.type = memory
cassandra_agent.channels.channel3.capacity = 1000
cassandra_agent.channels.channel3.transactionCapacity = 100
# custom Cassandra sink
cassandra_agent.sinks.sink3.type = com.veeru.flume.CustomCassandraSink
cassandra_agent.sinks.sink3.channel = channel3
----------------
Whenever I am running the agent I could see this error:
ERROR lifecycle.LifecycleSupervisor: Unable to start SinkRunner: {
policy:org.apache.flume.sink.DefaultSinkProcessor@28c1b980 counterGroup:{
name:null counters:{} } } - Exception follows.
java.lang.IllegalArgumentException:
Could someone help me out on this ?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
