Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
2.9.0
Description
The current active key needs to be set on Flink's state backend to support deleting pending timers on timer registration or firing. A keyed map for pending timers is necessary because Flink only allows deleting/resetting timers by their original time, not by their ids.
Setting the current active key can interfere with accessing user-defined state, but can also interfere when a timer is set at the same time that a timer fires. In cases with a key initialized by the state requests, this would have caused pending timers to be associated with the wrong key which would have led to problems deleting / resetting them.
Attachments
Issue Links
- is related to
-
BEAM-867 Support set/delete of timers by ID in Flink runner
- Resolved
- links to