flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Trying to comprehend rolling windows + event time
Date Fri, 19 Feb 2016 14:30:56 GMT
in the second case: do you know what watermark is emitted after ("grace", "arctic", 25) is
emitted? I imagine it is Long.MAX_VALUE, since otherwise all of the windows would not have
been triggered. If there are no intermittent watermarks but we directly jump to the last (Long.MAX_VALUE)
watermark then all in-flight windows will be emitted. The order in which they are emitted
is arbitrary and I guess the lone (“grace”, “arctic”, 25) seen first in the output
actually belongs to window (2 min to 7 min). 

Using a WindowFunction you could try and also print the window to which emitted elements belong.

> On 19 Feb 2016, at 13:23, lofifnc <alexander.kolb@mni.thm.de> wrote:
> I should add i'm using version 0.10.1
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Trying-to-comprehend-rolling-windows-event-time-tp5034p5035.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

View raw message