Roll back copiesRunning change in TaskSetManager

apache · Feb 5, 2015 · 48d5c1c · 48d5c1c
1 parent 3969f5f
commit 48d5c1c
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala
@@ -597,9 +597,7 @@ private[spark] class TaskSetManager(
     removeRunningTask(tid)
     info.markFailed()
     val index = info.index
-    if (copiesRunning(index) >= 1) {
-      copiesRunning(index) -= 1
-    }
+    copiesRunning(index) -= 1
     var taskMetrics : TaskMetrics = null
 
     val failureReason = s"Lost task ${info.id} in stage ${taskSet.id} (TID $tid, ${info.host}): " +