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 2017/07/31 12:32:27 UTC
flink git commit: [FLINK-6213] [yarn] terminate resource manager
itself when shutting down application
Repository: flink
Updated Branches:
refs/heads/master c5b61063e -> 67e431dea
[FLINK-6213] [yarn] terminate resource manager itself when shutting down application
This closes #3640.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/67e431de
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/67e431de
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/67e431de
Branch: refs/heads/master
Commit: 67e431deae364f2136355b03b0c4e9f6e487e90b
Parents: c5b6106
Author: fengyelei <fe...@huawei.com>
Authored: Wed Mar 29 11:40:24 2017 +0800
Committer: Till Rohrmann <tr...@apache.org>
Committed: Mon Jul 31 14:03:10 2017 +0200
----------------------------------------------------------------------
.../main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/67e431de/flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java
index 4626a7e..66e44a6 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java
@@ -298,6 +298,9 @@ public class YarnFlinkResourceManager extends FlinkResourceManager<RegisteredYar
} catch (Throwable t) {
LOG.error("Could not cleanly shut down the Node Manager Client", t);
}
+
+ // stop the actor after finishing processing the stop message
+ getContext().system().stop(getSelf());
}
@Override