Thanks you. I can be sure this way is correct now. I have tried this but the windows are not aggregating as well. Instead, the AllWindowFunction only works as flatMap. Shouldn't it only output for one window range? The most strange part is the first output is aggregating while others are not.
1> (68,2016-02-18T12:00:00.00,2016-02-18T12:10:00.00) 1> (1,2016-02-18T12:00:00.00,2016-02-18T12:10:00.00) 1> (1,2016-02-18T12:00:00.00,2016-02-18T12:10:00.00) 1> (1,2016-02-18T12:00:00.00,2016-02-18T12:10:00.00) .... When running 0.10.2 version the output is correct that the window time is not overlap (I'm using tumbling window) 1> (8,2016-02-18T12:00:00.00,2016-02-18T12:10:00.00) 1> (5,2016-02-18T12:10:00.00,2016-02-18T12:20:00.00) 1> (6,2016-02-18T12:20:00.00,2016-02-18T12:30:00.00) 1> (3,2016-02-18T12:30:00.00,2016-02-18T12:40:00.00) .... Perhaps I should look into other issues. Best, Hung -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/The-way-to-itearte-instances-in-AllWindowFunction-in-current-Master-branch-tp5137p5148.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
