Stephan Ewen created FLINK-6665: ----------------------------------- Summary: Pass a ScheduledExecutorService to the RestartStrategy Key: FLINK-6665 URL: https://issues.apache.org/jira/browse/FLINK-6665 Project: Flink Issue Type: Sub-task Components: Distributed Coordination Reporter: Stephan Ewen Fix For: 1.3.0
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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)