[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 <[email protected]> Authored: Thu Nov 24 16:49:00 2016 +0400 Committer: zentol <[email protected]> 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();
