Hi Hung, after some discussion the way that window functions are used will change back to the way it was in 0.10.x, i.e. the Iterable is always part of the apply function.
Sorry for the inconvenience this has caused. Cheers, Aljoscha > On 26 Feb 2016, at 11:48, Aljoscha Krettek <aljos...@apache.org> wrote: > > Hi, > yes that seems to have been the issue. The Math.max() is used to ensure that > the timestamp does never decrease, because this is not allowed for a > watermark. > > Cheers, > Aljoscha >> On 26 Feb 2016, at 11:11, HungChang <unicorn.bana...@gmail.com> wrote: >> >> Ah! My incorrect code segment made the Watermark not going forward and always >> stay at the same moment in the past. Is that true and the issue? >> >> Cheers, >> >> 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-tp5137p5186.html >> Sent from the Apache Flink User Mailing List archive. mailing list archive >> at Nabble.com. >
