You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flume.apache.org by Trevor Francis <tr...@tgrahamcapital.com> on 2012/04/19 06:43:55 UTC

Flume Cassandra Sink Error

ERROR com.cloudera.flume.conf.SinkFactoryImpl: Could not find class org.apache.cassandra.plugins.flume.sink.LogsandraSyslogSink for plugin loading


currently have:

<property>
    <name>flume.plugin.classes</name>
    <value>org.apache.cassandra.plugins.flume.sink.SimpleCassandraSink,org.apache.cassandra.plugins.flume.sink.LogsandraSyslogSink</value>
    <description>Comma separated list of plugin classes</description>
  </property>

in the flume-site.xml

and exporting path
export FLUME_CLASSPATH=`pwd`/flume-cassandra-plugin-1.0.0.jar:`pwd`/uuid-3.2.0.jar:`pwd`/cassandra-thrift-1.0.6.jar

any ideas?

Trevor Francis

Re: Flume Cassandra Sink Error

Posted by alo alt <wg...@googlemail.com>.

Hi,

export the complete path (without pwd) among the flume path. Or copy / link the classes into flume's lib directory.

best,
 Alex 

--
Alexander Lorenz
http://mapredit.blogspot.com

On Apr 19, 2012, at 6:43 AM, Trevor Francis wrote:

> ERROR com.cloudera.flume.conf.SinkFactoryImpl: Could not find class org.apache.cassandra.plugins.flume.sink.LogsandraSyslogSink for plugin loading
> 
> 
> currently have:
> 
> <property>
>     <name>flume.plugin.classes</name>
>     <value>org.apache.cassandra.plugins.flume.sink.SimpleCassandraSink,org.apache.cassandra.plugins.flume.sink.LogsandraSyslogSink</value>
>     <description>Comma separated list of plugin classes</description>
>   </property>
> 
> in the flume-site.xml
> 
> and exporting path
> export FLUME_CLASSPATH=`pwd`/flume-cassandra-plugin-1.0.0.jar:`pwd`/uuid-3.2.0.jar:`pwd`/cassandra-thrift-1.0.6.jar
> 
> any ideas?
> 
> Trevor Francis
> 
>