We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a0b9860 commit 506cea6Copy full SHA for 506cea6
core/src/main/scala/org/apache/spark/deploy/worker/ExecutorRunner.scala
@@ -67,6 +67,11 @@ private[spark] class ExecutorRunner(
67
Runtime.getRuntime.addShutdownHook(shutdownHook)
68
}
69
70
+ /**
71
+ * kill executor process, wait for exit and notify worker to update resource status
72
+ *
73
+ * @param message the exception message which caused the executor's death
74
+ */
75
private def killProcess(message: Option[String]) {
76
if (process != null) {
77
logInfo("Killing process!")
0 commit comments