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.
