Hi I read Unbound stream (read from kafka) and grouped by value, but on low-throughput streams I have strange behavior:
stream.apply(Window.into(FixedWindows.of(Duration.millis(10)))).apply(GroupByKey.create()) or stream.apply( Window.into(FixedWindows.of(Duration.millis(10))) .triggering(Repeatedly.forever(AfterWatermark.pastEndOfWindow())) .apply(GroupByKey.create()) 1ms event1 3ms event2 11ms event3 - (triger window) 12ms event4 13ms event5 21ms event6 - (triger window) 22ms event7 23ms event8 <nothing next 5 min> 5m00ms event9 As result event7 and event8 stay in windows without processing next 5 min Window and GroupBy will create only on event9 Behavior can reproduce on DirectRunner and FlinkRunner. This is bug or incorrect using API from my side?
