diff options
| author | lianhuiwang <lianhuiwang09@gmail.com> | 2014-05-27 11:53:38 -0700 |
|---|---|---|
| committer | Aaron Davidson <aaron@databricks.com> | 2014-05-27 11:53:38 -0700 |
| commit | 95e4c9c6fb153b7f0aa4c442c4bdb6552d326640 (patch) | |
| tree | c4cecba5c0cfd65f2840b0009eb10813467dbeac /core | |
| parent | 549830b0db2c8b069391224f3a73bb0d7f397f71 (diff) | |
| download | spark-95e4c9c6fb153b7f0aa4c442c4bdb6552d326640.tar.gz spark-95e4c9c6fb153b7f0aa4c442c4bdb6552d326640.tar.bz2 spark-95e4c9c6fb153b7f0aa4c442c4bdb6552d326640.zip | |
bugfix worker DriverStateChanged state should match DriverState.FAILED
bugfix worker DriverStateChanged state should match DriverState.FAILED
Author: lianhuiwang <lianhuiwang09@gmail.com>
Closes #864 from lianhuiwang/master and squashes the following commits:
480ce94 [lianhuiwang] address aarondav comments
f2b5970 [lianhuiwang] bugfix worker DriverStateChanged state should match DriverState.FAILED
Diffstat (limited to 'core')
| -rwxr-xr-x | core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala index 8b6747977e..100de26170 100755 --- a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala +++ b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala @@ -317,10 +317,14 @@ private[spark] class Worker( state match { case DriverState.ERROR => logWarning(s"Driver $driverId failed with unrecoverable exception: ${exception.get}") + case DriverState.FAILED => + logWarning(s"Driver $driverId exited with failure") case DriverState.FINISHED => logInfo(s"Driver $driverId exited successfully") case DriverState.KILLED => logInfo(s"Driver $driverId was killed by user") + case _ => + logDebug(s"Driver $driverId changed state to $state") } masterLock.synchronized { master ! DriverStateChanged(driverId, state, exception) |