[jira] [Created] (FLINK-14057) Add Remove Other Timers to TimerService

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14057) Add Remove Other Timers to TimerService

Shang Yuanchun (Jira)
Jesse Anderson created FLINK-14057:
--------------------------------------

             Summary: Add Remove Other Timers to TimerService
                 Key: FLINK-14057
                 URL: https://issues.apache.org/jira/browse/FLINK-14057
             Project: Flink
          Issue Type: Improvement
            Reporter: Jesse Anderson


The TimerService service has the ability to add timers with registerProcessingTimeTimer. This method can be called many times and have different timer times.

If you want to add a new timer and delete other timers, you have to keep track of all previous timer times and call deleteProcessingTimeTimer for each time. This method forces you to keep track of all previous (unexpired) timers for a key.

Instead, I suggest overloading registerProcessingTimeTimer with a second boolean argument that will remove all previous timers and set the new timer.

Note: although I'm using registerProcessingTimeTimer, this applies to registerEventTimeTimer as well.



--
This message was sent by Atlassian Jira
(v8.3.2#803003)