Hi, the timers are not actually deleted but the WindowOperator will check whether there is any window state associated with the window for which the timer fires. If there is no window state the timer will silently be ignored.
Is this a problem for you or did you just want to clarify? If yes, then we should work on finding a solution. Cheers, Aljoscha On Tue, 8 Nov 2016 at 18:18 Konstantin Knauf <konstantin.kn...@tngtech.com> wrote: > Hi everyone, > > I just migrated a streaming Job from 1.0.2 to 1.1.3 and stumbled across > a problem concerning one of our custom triggers. > > The trigger basically FIRE_AND_PURGEs multiple times in onElement() and > the window is PURGEd onProcessingTimeTimer(), but it seems that the all > registered processing time timers are deleted everytime the window is > PURGEd. > > clear() is the default implementation, i.e. no-op. > > Just wanted to, if this is the expected behavior (processing time timers > being deleted on PURGE or FIRE_AND_PURGE) from Flink 1.1 on? > > Cheers, > > Konstantin > > -- > Konstantin Knauf * konstantin.kn...@tngtech.com * +49-174-3413182 > <0174%203413182> > TNG Technology Consulting GmbH, Betastr. 13a, 85774 Unterföhring > Geschäftsführer: Henrik Klagges, Christoph Stock, Dr. Robert Dahlke > Sitz: Unterföhring * Amtsgericht München * HRB 135082 > > >
