flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Kloudas <k.klou...@data-artisans.com>
Subject Re: Flink CEP not emitting timed out events properly
Date Tue, 20 Jun 2017 14:51:57 GMT
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 <revolutionisme@gmail.com> wrote:
> 
>  currentMaxTimestamp = currentMaxTimestamp + 1000;


Mime
View raw message