Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-17904

Add "scheduleWithFixedDelay" to ProcessingTimeService

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.11.0
    • Runtime / Task
    • None

    Description

      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".

      Attachments

        Activity

          People

            sewen Stephan Ewen
            sewen Stephan Ewen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: