blems... Can you post a minimal code example that reproduces the
problem?
Using print() will confuse the issue, since print() will try to only
use the first partition.
Use foreachRDD { rdd => rdd.foreach(println)
or something comparable
On Tue, Mar 22, 2016 at 10:14 AM, Martin Soch <
Hi all,
I am using direct-Kafka-input-stream in my Spark app. When I use
window(...) function in the chain it will cause the processing pipeline
to stop - when I open the Spark-UI I can see that the streaming batches
are being queued and the pipeline reports to process one of the first
-
To unsubscribe e-mail: user-unsubscr...@spark.apache.org
