remove redundant code

pdeyhim · Jun 6, 2014 · 7b0177a · 7b0177a
1 parent c7b93b5
commit 7b0177a
Showing 1 changed file with 0 additions and 4 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
@@ -188,9 +188,6 @@ private[spark] class TaskSetManager(
     var hadAliveLocations = false
     for (loc <- tasks(index).preferredLocations) {
       for (execId <- loc.executorId) {
-        if (sched.isExecutorAlive(execId)) {
-          hadAliveLocations = true
-        }
         addTo(pendingTasksForExecutor.getOrElseUpdate(execId, new ArrayBuffer))
       }
       if (sched.hasExecutorsAliveOnHost(loc.host)) {
@@ -756,7 +753,6 @@ private[spark] class TaskSetManager(
     def newLocAvail(index: Int): Boolean = {
       for (loc <- tasks(index).preferredLocations) {
         if (sched.hasExecutorsAliveOnHost(loc.host) ||
-          (loc.executorId.isDefined && sched.isExecutorAlive(loc.executorId.get)) ||
           sched.getRackForHost(loc.host).isDefined) {
           return true
         }