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
