Hi Aljoscha,
Thanks for the information. In my case I didn't clean up the state
explicitly in Trigger.onMerge(). Only
OnMergeContext.mergePartitionedState(stateDesc) is called within my
implementation, with the intention to copy the states from merged windows
and re-register the timers.
However,
Hi,
I think you should be able to use state for cleaning up your timers in
Trigger.clear(). For this, you have to make sure to not clean up the state in
Trigger.onMerge() and instead remove it in Trigger.clear().
I'm not sure whether this will be possible for your use case, though.
Best,
Hi,
I think that it is currently not possible to delete timers that did not
trigger, because currently some of the data structures used for timers do not
support random deletes efficiently. For the second part of the question about
keeping the state of merged windows, I added Aljoscha in CC
Hi,
I am implementing a merge-able trigger, and having a problem in clearing
the registered timers for a merged window (a window has been merged into
the merging result). For my implementation, the trigger registers multiple
timers for each element at Trigger#onElement(). State is used to keep
