Re: Flink CEP not emitting timed out events properly

Posted by Kostas Kloudas on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-CEP-not-emitting-timed-out-events-properly-tp13794p13861.html

Are you sure that after incrementing the wm by 1sec, there is no 

element that will come with a timestamp smaller than this? Or,

that after 10sec of inactivity, no element will come with such a 

timestamp?

Kostas

On Jun 20, 2017, at 4:18 PM, Biplob Biswas <[hidden email]> wrote:

 currentMaxTimestamp = currentMaxTimestamp + 1000;