Skip to content

Commit 9c19ce6

Browse files
committed
Kill drivers in postStop() for Worker.
JIRA SPARK-1068:https://spark-project.atlassian.net/browse/SPARK-1068
1 parent 3a9d82c commit 9c19ce6

File tree

1 file changed

+1
-0
lines changed
  • core/src/main/scala/org/apache/spark/deploy/worker

1 file changed

+1
-0
lines changed

core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala

100644100755
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -325,6 +325,7 @@ private[spark] class Worker(
325325

326326
override def postStop() {
327327
executors.values.foreach(_.kill())
328+
drivers.values.foreach(_.kill())
328329
webUi.stop()
329330
metricsSystem.stop()
330331
}

0 commit comments

Comments
 (0)