From 941a4fdb93786a2a68437475271ebe59fac53f36 Mon Sep 17 00:00:00 2001 From: CodingCat Date: Thu, 31 Jul 2014 07:49:53 -0400 Subject: [PATCH] see my shocked face.......... --- .../scala/org/apache/spark/scheduler/TaskSetManager.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 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 index 88e2d445c5210..08462bd7e1837 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala @@ -114,7 +114,7 @@ private[spark] class TaskSetManager( // but at host level. private val pendingTasksForHost = new HashMap[String, ArrayBuffer[Int]] - private var hasNodeLocalOnlyTasks = true + private var hasNodeLocalOnlyTasks = false // Set of pending tasks for each rack -- similar to the above. private val pendingTasksForRack = new HashMap[String, ArrayBuffer[Int]] @@ -416,7 +416,7 @@ private[spark] class TaskSetManager( var allowedLocality = maxLocality - if (maxLocality != TaskLocality.NO_PREF) {// } || hasNodeLocalOnlyTasks) { + if (maxLocality != TaskLocality.NO_PREF || hasNodeLocalOnlyTasks) { allowedLocality = getAllowedLocalityLevel(curTime) if (allowedLocality > maxLocality) { // We're not allowed to search for farther-away tasks