[jira] [Resolved] (FLUME-2836) Flume and Cassandra sink

["Ashish Paliwal (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLUME-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ashish Paliwal resolved FLUME-2836.
-----------------------------------
    Resolution: Won't Fix

ML question

> 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)