Hi Biplop, Your recent post on reading from different topics made me realise it may be a problem with "stalled" partitions. Did your topic have more than one partition? If it did, it may be the problem that Watermark is generated independently per partition and then the smallest one is taken as a "global" Watermark.
Z pozdrowieniami! / Cheers! Dawid Wysakowicz *Data/Software Engineer* Skype: dawid_wys | Twitter: @OneMoreCoder <http://getindata.com/> 2017-06-08 15:35 GMT+02:00 Biplob Biswas <revolutioni...@gmail.com>: > Hi, > > Can anyone check, whether they can reproduce this issue on their end? > There's no log yet as t what is happening. Any idea to debug this issue is > well appreciated. > > Regards, > Biplob > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Queries-regarding-FlinkCEP- > tp13454p13591.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
