提交 a13ba7b3 编写于 作者: T Till Rohrmann

Add proper web monitor shutdown to standalone mode

Before the WebRuntimeMonitor was not properly stopped after the ActorSystem has
been terminated.
上级 49ce6f7b
......@@ -2027,7 +2027,7 @@ object JobManager {
listeningPort: Int)
: Unit = {
val (jobManagerSystem, _, _, _, _) = startActorSystemAndJobManagerActors(
val (jobManagerSystem, _, _, webMonitorOption, _) = startActorSystemAndJobManagerActors(
configuration,
executionMode,
listeningAddress,
......@@ -2039,6 +2039,16 @@ object JobManager {
// block until everything is shut down
jobManagerSystem.awaitTermination()
webMonitorOption.foreach{
webMonitor =>
try {
webMonitor.stop()
} catch {
case t =>
LOG.warn("Could not properly stop the web monitor.", t)
}
}
}
/**
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册