Re: Allowed lateness + side output late data, what's included?

2018-04-11 Thread Juho Autio
Thanks! On Wed, Apr 11, 2018 at 12:59 PM, Chesnay Schepler wrote: > 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 lat

Re: Allowed lateness + side output late data, what's included?

2018-04-11 Thread Chesnay Schepler
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 allow

Allowed lateness + side output late data, what's included?

2018-04-11 Thread Juho Autio
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