Kill drivers in postStop() for Worker. JIRA SPARK-1068:https://spark-project.atlassian.net/browse/SPARK-1068 Author: Qiuzhuang Lian <Qiuzhuang.Lian@gmail.com> == Merge branch commits == commit 9c19ce63637eee9369edd235979288d3d9fc9105 Author: Qiuzhuang Lian <Qiuzhuang.Lian@gmail.com> Date: Sat Feb 8 16:07:39 2014 +0800 Kill drivers in postStop() for Worker. JIRA SPARK-1068:https://spark-project.atlassian.net/browse/SPARK-1068
This commit is contained in:
parent
78050805bc
commit
f0ce736fad
1
core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
Normal file → Executable file
1
core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
Normal file → Executable file
|
@ -325,6 +325,7 @@ private[spark] class Worker(
|
||||||
|
|
||||||
override def postStop() {
|
override def postStop() {
|
||||||
executors.values.foreach(_.kill())
|
executors.values.foreach(_.kill())
|
||||||
|
drivers.values.foreach(_.kill())
|
||||||
webUi.stop()
|
webUi.stop()
|
||||||
metricsSystem.stop()
|
metricsSystem.stop()
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue