Hi Francis,
I'm afraid this is a very strange bug that results from the interplay
between pre-aggregating (an optimization that pre-aggregates the elements
of a window as they arrive) and the window size/slide size you use. When
using some other time values it works, but with other it doesn't, agai
Testing the apache flink stream API, I found something weird with a simple
example.
This code counts the words every 5 seconds under a window of 10 seconds. Until
the 10 first seconds, counts sound good, after that, every print shows a wrong
count - one per word. There is something wrong in my