flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dawid Wysakowicz <wysakowicz.da...@gmail.com>
Subject Re: Queries regarding FlinkCEP
Date Tue, 20 Jun 2017 12:21:17 GMT
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 <revolutionisme@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.
>

Mime
View raw message