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