[FLINK-9619] Eagerly close the connection with task manager when the container is completed.
This closes #6185. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9ad0a07 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c9ad0a07 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c9ad0a07 Branch: refs/heads/master Commit: c9ad0a07ef0339ced74057fc17800ca9ab7784c1 Parents: 134e044 Author: sihuazhou <summerle...@163.com> Authored: Wed Jun 20 12:41:05 2018 +0800 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Fri Jul 13 18:32:57 2018 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/yarn/YarnResourceManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c9ad0a07/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---------------------------------------------------------------------- diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java index 9dd9922..96ec57e 100644 --- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java +++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java @@ -336,8 +336,9 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme // Container completed unexpectedly ~> start a new one final Container container = yarnWorkerNode.getContainer(); internalRequestYarnContainer(container.getResource(), yarnWorkerNode.getContainer().getPriority()); - closeTaskManagerConnection(resourceId, new Exception(containerStatus.getDiagnostics())); } + // Eagerly close the connection with task manager. + closeTaskManagerConnection(resourceId, new Exception(containerStatus.getDiagnostics())); } } );
