[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fang Yong reassigned FLINK-6665: -------------------------------- Assignee: Fang Yong > 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 > Assignee: Fang Yong > Fix For: 1.4.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.4.14#64029)