You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/11/27 11:51:34 UTC
[3/4] flink git commit: [FLINK-4741] Proper shutdown the
ServerBootstrap WebRuntimeMonitor
[FLINK-4741] Proper shutdown the ServerBootstrap WebRuntimeMonitor
This closes #2862.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/333da3ac
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/333da3ac
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/333da3ac
Branch: refs/heads/master
Commit: 333da3ac8f8b05c3e3194ba0b376300b403bc2c8
Parents: 7d34f65
Author: Roman Maier <ro...@epam.com>
Authored: Thu Nov 24 16:49:00 2016 +0400
Committer: zentol <ch...@apache.org>
Committed: Sun Nov 27 10:59:12 2016 +0100
----------------------------------------------------------------------
.../org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/333da3ac/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java
----------------------------------------------------------------------
diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java
index 479b4ac..c5b7d35 100644
--- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java
+++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java
@@ -458,6 +458,9 @@ public class WebRuntimeMonitor implements WebMonitor {
if (bootstrap.group() != null) {
bootstrap.group().shutdownGracefully();
}
+ if (bootstrap.childGroup() != null) {
+ bootstrap.childGroup().shutdownGracefully();
+ }
}
stackTraceSamples.shutDown();