flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Allowed lateness + side output late data, what's included?
Date Wed, 11 Apr 2018 09:59:16 GMT
Data that arrives within the allowed lateness should not be written to 
the side output.

On 11.04.2018 11:12, Juho Autio wrote:
> If I use a non-zero value for allowedLateness and also 
> sideOutputLateData, does the late data output contain also the events 
> that were triggered in the bounds of allowed lateness? By looking at 
> the docs I can't be sure which way it is.
> Code example:
> .timeWindow(Time.days(1))
> .allowedLateness(Time.minutes(1))
> .sideOutputLateData(lateDataTag)
> Also I know that data that arrives more than 1 minute late is written 
> to the late data side output.
> If some data arrives 0-1 minute late, I know that the time window 
> triggers again with that data added. Is that data also written to the 
> late data side output or not?
> Thanks!

View raw message