flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From M Singh <mans2si...@yahoo.com>
Subject Re: Apache Flink - Question about TriggerResult.FIRE
Date Sat, 25 Nov 2017 17:07:11 GMT
Another question - what happens if the trigger never calls PURGE or FIRE_AND_PURGE and only
calls FIRE ?  Are the window and it's contents removed after the end time + lateness are
exceeded ?

    On Monday, November 20, 2017 2:18 AM, Stefan Richter <s.richter@data-artisans.com>


"In the first case, it is a new window without the previous elements, in the second case the
window reflects the old contents plus all changes since the last trigger."
I am assuming the first case is FIRE and second case is FIRE_AND_PURGE - I was thinking that
in the first case (FIRE), there would be elements from previous window since we did not purge
and the second case it would have only new elements since it was purged.  Am I missing something


No, with first case, I meant the „truly new window case“ and the second case is „another
triggering of the previous (non-purged) window“. So the second case is a simple FIRE without

View raw message