Ufuk Celebi created FLINK-3443: ---------------------------------- Summary: JobManager cancel and clear everything fails jobs instead of cancelling Key: FLINK-3443 URL: https://issues.apache.org/jira/browse/FLINK-3443 Project: Flink Issue Type: Bug Components: Distributed Runtime Reporter: Ufuk Celebi Assignee: Ufuk Celebi
When the job manager is shut down, it calls {{cancelAndClearEverything}}. This method does not {{cancel}} the {{ExecutionGraph}} instances, but {{fail}}s them, which can lead to {{ExecutionGraph}} restart. I've noticed this in tests, where old graph got into a loop of restarts. What I don't understand is why the futures etc. are not cancelled when the executor service is shut down. -- This message was sent by Atlassian JIRA (v6.3.4#6332)