Stephan Ewen created FLINK-17904:
------------------------------------
Summary: Add "scheduleWithFixedDelay" to ProcessingTimeService
Key: FLINK-17904
URL:
https://issues.apache.org/jira/browse/FLINK-17904 Project: Flink
Issue Type: Improvement
Components: Runtime / Task
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Adding {{"scheduleWithFixedDelay(...)"}} to {{ProcessingTimeService}} better support cases where fired timers are backed up. Rather than immediately firing again, they would wait their scheduled delay.
The implementation can be added in ProcessingTimeService in the exact same way as {{"scheduleAtFixedRate"}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)