> 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,
$ 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
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/