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

Reply via email to