The documentation says https://flink.apache.org/news/2015/12/04/Introducing-windows.html wrote > On each event, a trigger can decide to fire (i.e., evaluate), purge > (remove the window and discard its content), or fire and then purge the > window. A trigger that just fires evaluates the window and keeps it as it > is, i.e., all elements remain in the window and are evaluated again when > the triggers fires the next time.
So you can choose between *Fire*, *Purge* and *Fire&Purge*. Seems like selected *Fire* but meant to choose *Fire&Purge*. >From what it seems you want a PurgingTrigger. You also didn't state what version of Flink you are using :) -- Jonas -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Expected-behaviour-of-windows-tp11200p11205.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.