Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6664 Extend Restart Strategy for Fine-grained Recovery and missing Resources
  3. FLINK-6665

Pass a ScheduledExecutorService to the RestartStrategy

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.3.2, 1.4.0
    • Runtime / Coordination
    • None

    Description

      Currently, the RestartStrategy is called when the ExecutionGraph should be restarted.

      To facilitate delays before restarting, the strategy simply sleeps, blocking the thread that runs the ExecutionGraph's recovery method.

      I suggest to pass ScheduledExecutorService) to the RestartStrategy and let it schedule the restart call that way, avoiding any sleeps.

      Attachments

        Issue Links

          is duplicated by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-2263 ExecutionGraph uses Thread.sleep to delay execution retries

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #4220

          Activity

            People

              zjureel Fang Yong
              sewen Stephan Ewen
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: