You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by Gianluca Privitera <gi...@studio.unibo.it> on 2014/06/06 23:44:29 UTC

Spark Streaming window functions bug 1.0.0

Is anyone experiencing problems with windows?

dstream1.print()
val dstream2 = dstream1.groupByKeyAndWindow(Seconds(60))
dstream2.print()

In my appslication the first print() prints out all the strings and 
their keys, but after the window function everything is lost and 
nothings gets printed.
I'm using Spark version 1.0.0 on a EC2 Cluster.

Thanks
Gianluca