Hi Aljoscha, interesting, this explains it. Well, in our case the PURGE in the onProcessingTimeTimer is only used to clear KeyValueStates*, and at this point there are usually no records in the window state.
Any Ideas? I do have a workaround with an evictor, but it seemed to be unnecessarily complicated. *We can not use clear()-callback for that, since this state should survive the FIRE_AND_PURGEs in the onElement()-calls. Cheers, Konstantin On 08.11.2016 18:31, Aljoscha Krettek wrote: > 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 <mailto: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 > <mailto:konstantin.kn...@tngtech.com> * +49-174-3413182 > <tel: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 > > -- Konstantin Knauf * konstantin.kn...@tngtech.com * +49-174-3413182 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
signature.asc
Description: OpenPGP digital signature
