Re: Flume with Spark Streaming Sink

2016-03-20 Thread Luciano Resende
> flumeStream.print > ssc.start > > > And getting this execption. > > 16/03/20 18:17:17 INFO scheduler.ReceiverTracker: Registered receiver for > stream 0 from impact3.indigo.co.il:51581 > 16/03/20 18:17:17 WARN scheduler.TaskSetManager: Lost task 0.0 in stage > 4.0 (TID 76,

Re: Flume with Spark Streaming Sink

2016-03-20 Thread Ted Yu
$ jar tvf ./external/flume-sink/target/spark-streaming-flume-sink_2.10-1.6.1.jar | grep SparkFlumeProtocol 841 Thu Mar 03 11:09:36 PST 2016 org/apache/spark/streaming/flume/sink/SparkFlumeProtocol$Callback.class 2363 Thu Mar 03 11:09:36 PST 2016 org/apache/spark/streaming/flume/sink

Flume with Spark Streaming Sink

2016-03-20 Thread Daniel Haviv
execption. 16/03/20 18:17:17 INFO scheduler.ReceiverTracker: Registered receiver for stream 0 from impact3.indigo.co.il:51581 16/03/20 18:17:17 WARN scheduler.TaskSetManager: Lost task 0.0 in stage 4.0 (TID 76, impact3.indigo.co.il): java.lang.NoClassDefFoundError: org/apache/spark/streaming/