Re: Simple streaming word count doesn't work (Scala)

2015-09-14 Thread Aljoscha Krettek
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

Simple streaming word count doesn't work (Scala)

2015-09-14 Thread Francis Aranda
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