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 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
