Hi, Why don’t you set the allowed lateness to Long.MAX_VALUE? This way no data will ever be considered late. If you make the trigger via PurgingTrigger.of(EventTimeTrigger.of(…)). You ensure that window state is not kept after a window fires.
Best, Aljoscha > On 17. May 2017, at 13:39, rizhashmi <rizhas...@hotmail.com> wrote: > > Yes .. is there any possibility access flink state variables in > WindowAssigner.assignWindows method? > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/State-in-Custom-Tumble-Window-Class-tp13177p13196.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
