(DEPRECATED) Apache Flink User Mailing List archive.

Re: Queries regarding FlinkCEP

Posted by Dawid Wysakowicz on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Queries-regarding-FlinkCEP-tp13454p13855.html

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.

Z pozdrowieniami! / Cheers!

Dawid Wysakowicz

Data/Software Engineer

Skype: dawid_wys | Twitter: @OneMoreCoder

2017-06-20 14:00 GMT+02:00 Biplob Biswas <[hidden email]>:

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.