For example if there is no events in one of the partitions the partition will always generate Watermark(Long.MIN_VALUE) which will result in Watermark not being advanced. There is open JIRA to improve such situations: FLINK-5479 <https://issues.apache.org/jira/browse/FLINK-5479>.
Z pozdrowieniami! / Cheers! Dawid Wysakowicz *Data/Software Engineer* Skype: dawid_wys | Twitter: @OneMoreCoder <http://getindata.com/> 2017-06-20 14:00 GMT+02:00 Biplob Biswas <revolutioni...@gmail.com>: > Hi dawid, > > Yes I am reading from multiple topics and yes a few topics have multiple > partitions, not all of them. > > But I didn't understand the concept of stalled partition. > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Queries-regarding-FlinkCEP- > tp13454p13853.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
