remove hasNodeLocalOnlyTasks

apache · Aug 4, 2014 · 9b9432f · 9b9432f
1 parent fdd1573
commit 9b9432f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala
@@ -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