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. Thanks -Ashish On Sun, Apr 15, 2018 at 10:09 PM, Tzu-Li (Gordon) Tai <tzuli...@apache.org> wrote: > 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/ > -- Thanks -Ashish Attarde