diff options
| author | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-13 21:51:47 -0800 |
|---|---|---|
| committer | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-13 22:37:16 -0800 |
| commit | c528932a41000835af316382309a1465cb94f582 (patch) | |
| tree | a9676430169fa7d646f91c603ffcd435edf727ed /core | |
| parent | 0aad42b5e732ac6865b8e3c2cffa35d4ff48d5ca (diff) | |
| download | spark-c528932a41000835af316382309a1465cb94f582.tar.gz spark-c528932a41000835af316382309a1465cb94f582.tar.bz2 spark-c528932a41000835af316382309a1465cb94f582.zip | |
Code review cleanup.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala b/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala index 7b58d0c022..e2301347e5 100644 --- a/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala +++ b/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala @@ -72,7 +72,10 @@ private[spark] class SparkDeploySchedulerBackend( } def executorRemoved(id: String, message: String, exitStatus: Option[Int]) { - var reason: ExecutorLossReason = exitStatus.map(ExecutorExited).getOrElse(SlaveLost(message)) + val reason: ExecutorLossReason = exitStatus match { + case Some(code) => ExecutorExited(code) + case None => SlaveLost(message) + } logInfo("Executor %s removed: %s".format(id, message)) executorIdToSlaveId.get(id) match { case Some(slaveId) => |