Hi, could you please share code (and example data) for producing this output. I'd like to have a look.
Cheers, Aljoscha On Wed, 21 Dec 2016 at 16:29 Nico <nico.franz...@gmail.com> wrote: > Hi @all, > > I am using a TumblingEventTimeWindows.of(Time.seconds(20)) for testing. > During this I found a strange behavior (at least for me) in the assignment > of events. > > The first element of a new window is actually always part of the old > window. I thought the events are late, but then they they would be dropped > instead of assigned to the new window. Even with a allowedLateness of 10s > the behavior remains the same. > > The used timeWindow.getStart() and getEnd in order to get the boundaries > of the window. > > Can someone explain this? > > Best, > Nico > > > TimeWindows with Elements: > > Start: 1482332940000 - End: 1482332960000 > timestamp=1482332952907 > > Start: 1482332960000 - End: 1482332980000 > timestamp=1482332958929 > timestamp=1482332963995 > timestamp=1482332969027 > timestamp=1482332974039 > > Start: 1482332980000 - End: 1482333000000 > timestamp=1482332979059 > timestamp=1482332984072 > timestamp=1482332989081 > timestamp=1482332994089 > > Start: 1482333000000 - End: 1482333020000 > timestamp=1482332999113 > timestamp=1482333004123 > timestamp=1482333009132 > timestamp=1482333014144 >
