From 49b779279a1b3bf7a061982d3511f37e3dfdb213 Mon Sep 17 00:00:00 2001 From: zsxwing Date: Sat, 17 Oct 2015 11:41:21 +0800 Subject: [PATCH] Revert the change to core --- .../main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 947feda3b34aa..c02597c4365c9 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala @@ -388,7 +388,7 @@ private[spark] class TaskSetManager( if (TaskLocality.isAllowed(maxLocality, TaskLocality.NO_PREF)) { // Look for noPref tasks after NODE_LOCAL for minimize cross-rack traffic for (index <- dequeueTaskFromList(execId, pendingTasksWithNoPrefs)) { - return Some((index, TaskLocality.NO_PREF, false)) + return Some((index, TaskLocality.PROCESS_LOCAL, false)) } }