You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/07/14 05:52:30 UTC
[10/12] flink git commit: [FLINK-9619] Eagerly close the connection
with task manager when the container is completed.
[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 <su...@163.com>
Authored: Wed Jun 20 12:41:05 2018 +0800
Committer: Till Rohrmann <tr...@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()));
}
}
);