diff options
| author | Imran Rashid <imran@quantifind.com> | 2012-11-07 15:35:51 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-11-08 00:34:28 -0800 |
| commit | 809b2bb1fe92c8ce733ce082c5f6e31316e05a61 (patch) | |
| tree | dbac69da9775a2de1c5ac640f5527c3194c36f6f | |
| parent | bb1bce79240da22c2677d9f8159683cdf73158c2 (diff) | |
| download | spark-809b2bb1fe92c8ce733ce082c5f6e31316e05a61.tar.gz spark-809b2bb1fe92c8ce733ce082c5f6e31316e05a61.tar.bz2 spark-809b2bb1fe92c8ce733ce082c5f6e31316e05a61.zip | |
fix bug in getting slave id out of mesos
| -rw-r--r-- | core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala b/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala index cdfe1f2563..814443fa52 100644 --- a/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala +++ b/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala @@ -272,7 +272,7 @@ private[spark] class MesosSchedulerBackend( synchronized { slaveIdsWithExecutors -= slaveId.getValue } - scheduler.slaveLost(slaveId.toString) + scheduler.slaveLost(slaveId.getValue) } override def executorLost(d: SchedulerDriver, e: ExecutorID, s: SlaveID, status: Int) { |