Skip to content
Snippets Groups Projects
Commit 871476d5 authored by Stephen Haberman's avatar Stephen Haberman
Browse files

Include message and exitStatus if availalbe.

parent d54b10b6
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
core/src/main/scala/spark/deploy/worker/Worker.scala
+ 3
− 1
View file @ 871476d5
...@@ -134,7 +134,9 @@ private[spark] class Worker( ...@@ -134,7 +134,9 @@ private[spark] class Worker(
val fullId = jobId + "/" + execId val fullId = jobId + "/" + execId
if (ExecutorState.isFinished(state)) { if (ExecutorState.isFinished(state)) {
val executor = executors(fullId) val executor = executors(fullId)
logInfo("Executor " + fullId + " finished with state " + state) logInfo("Executor " + fullId + " finished with state " + state +
message.map(" message " + _).getOrElse("") +
exitStatus.map(" exitStatus " + _).getOrElse(""))
finishedExecutors(fullId) = executor finishedExecutors(fullId) = executor
executors -= fullId executors -= fullId
coresUsed -= executor.cores coresUsed -= executor.cores
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment