Bug fix from Justin

2010-08-13 11:29:19 -07:00 · 2010-08-13 11:29:19 -07:00 · 3d8d7fd557
parent a9481c3514
commit 3d8d7fd557
1 changed files with 1 additions and 1 deletions
--- a/src/scala/spark/MesosScheduler.scala
+++ b/src/scala/spark/MesosScheduler.scala
@ -279,7 +279,7 @@ extends ParallelOperation
  def taskLost(status: TaskStatus) {
    val tid = status.getTaskId
    println("Lost TID " + tid)
-    if (!finished(tid)) {
+    if (!finished(tidToIndex(tid))) {
      launched(tidToIndex(tid)) = false
      tasksLaunched -= 1
    } else {