Thanks Gordon for your reply.

The out file mistry got resolved. Someone accidently, modified the POJO
code on server that I work on to, and had put in println.

Thank you for the information. I am experimenting with windowing to
understand better and fit in my use case.


On Sun, Apr 15, 2018 at 10:09 PM, Tzu-Li (Gordon) Tai <>

> 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.


-Ashish Attarde

Reply via email to