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 506cea6 commit 21d380bCopy full SHA for 21d380b
core/src/main/scala/org/apache/spark/deploy/worker/ExecutorRunner.scala
@@ -61,7 +61,7 @@ private[spark] class ExecutorRunner(
61
// Shutdown hook that kills actors on shutdown.
62
shutdownHook = new Thread() {
63
override def run() {
64
- killProcess(None)
+ killProcess(Some("Worker shutting down"))
65
}
66
67
Runtime.getRuntime.addShutdownHook(shutdownHook)
@@ -159,7 +159,7 @@ private[spark] class ExecutorRunner(
159
case e: Exception => {
160
logError("Error running executor", e)
161
state = ExecutorState.FAILED
162
- killProcess(Some(e.getClass + ":" + e.getMessage))
+ killProcess(Some(e.toString))
163
164
165
0 commit comments