File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
core/src/main/scala/org/apache/spark/deploy/worker Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -312,11 +312,13 @@ private[spark] class Worker(
312312 case DriverState .ERROR =>
313313 logWarning(s " Driver $driverId failed with unrecoverable exception: ${exception.get}" )
314314 case DriverState .FAILED =>
315- logWarning(s " Driver $driverId failed with state $state " )
315+ logWarning(s " Driver $driverId exited with failure " )
316316 case DriverState .FINISHED =>
317317 logInfo(s " Driver $driverId exited successfully " )
318318 case DriverState .KILLED =>
319319 logInfo(s " Driver $driverId was killed by user " )
320+ case _ =>
321+ logDebug(s " Driver $driverId changed state to $state" )
320322 }
321323 masterLock.synchronized {
322324 master ! DriverStateChanged (driverId, state, exception)
You can’t perform that action at this time.
0 commit comments