Hi Ashish, I don't really see why there are outputs in the out file for the program you provided. Perhaps others could chime in here ..
As for your second question regarding window outputs: Yes, subsequent window operators should definitely be doable in Flink. This is just a matter of multiple transformations in your pipeline. The only restriction right now, is that after a window operation, the stream is no longer a KeyedStream, so you would need to "re-key" the stream before applying the second windowed transformation. Cheers, Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
