You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/11/13 10:39:00 UTC
[jira] [Updated] (FLINK-14057) Add Remove Other Timers to TimerService
[ https://issues.apache.org/jira/browse/FLINK-14057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-14057:
-----------------------------------
Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized.
> Add Remove Other Timers to TimerService
> ---------------------------------------
>
> Key: FLINK-14057
> URL: https://issues.apache.org/jira/browse/FLINK-14057
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream
> Reporter: Jesse Anderson
> Priority: Minor
> Labels: auto-deprioritized-major, stale-minor
>
> 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.20.1#820001)