RE: TimeWindow not getting last elements any longer with flink 1.0 vs 0.10.1

2016-03-15 Thread LINZ, Arnaud
. Cheers, Arnaud De : Till Rohrmann [mailto:trohrm...@apache.org] Envoyé : lundi 14 mars 2016 15:11 À : user@flink.apache.org Objet : Re: TimeWindow not getting last elements any longer with flink 1.0 vs 0.10.1 Hi Arnaud, with version 1.0 the behaviour for window triggering in case of a finite

Re: TimeWindow not getting last elements any longer with flink 1.0 vs 0.10.1

2016-03-14 Thread Till Rohrmann
Hi Arnaud, with version 1.0 the behaviour for window triggering in case of a finite stream was slightly changed. If you use event time, then all unfinished windows are triggered in case that your stream ends. This can be motivated by the fact that the end of a stream is equivalent to no elements w

TimeWindow not getting last elements any longer with flink 1.0 vs 0.10.1

2016-03-14 Thread LINZ, Arnaud
Hello, I’ve switched my Flink version from 0.10.1 to 1.0 and I have a regression in some of my unit tests. To narrow the problem, here is what I’ve figured out: - I use a simple Streaming application with a source defined as “fromElements("Element 1", "Element 2", "Element 3") -