Re: Spark Streaming action not triggered with Kafka inputs

ssc.union will return a DStream, you should do something like: val lines = ssc.union(parallelInputs) lines.print() Thanks Best Regards On Sat, Jan 24, 2015 at 12:55 AM, Chen Song wrote: > I am running into some problems with Spark Streaming when reading from > Kafka.I used Spark 1.2.0 built o

Spark Streaming action not triggered with Kafka inputs

I am running into some problems with Spark Streaming when reading from Kafka.I used Spark 1.2.0 built on CDH5. The example is based on: https://github.com/apache/spark/blob/master/examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala * It works with default imp