Rename variables

apache · Aug 30, 2016 · 321d0c6 · 321d0c6
1 parent 5d20b44
commit 321d0c6
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala
@@ -325,13 +325,13 @@ private[spark] class TaskSchedulerImpl(
     // NOTE: the preferredLocality order: PROCESS_LOCAL, NODE_LOCAL, NO_PREF, RACK_LOCAL, ANY
     for (taskSet <- sortedTaskSets) {
       var launchedAnyTask = false
-      var launchedTaskAtMaxLocality = false
-      for (maxLocality <- taskSet.myLocalityLevels) {
+      var launchedTaskAtCurrentMaxLocality = false
+      for (currentMaxLocality <- taskSet.myLocalityLevels) {
         do {
-          launchedTaskAtMaxLocality = resourceOfferSingleTaskSet(
-            taskSet, maxLocality, shuffledOffers, availableCpus, tasks)
-          launchedAnyTask |= launchedTaskAtMaxLocality
-        } while (launchedTaskAtMaxLocality)
+          launchedTaskAtCurrentMaxLocality = resourceOfferSingleTaskSet(
+            taskSet, currentMaxLocality, shuffledOffers, availableCpus, tasks)
+          launchedAnyTask |= launchedTaskAtCurrentMaxLocality
+        } while (launchedTaskAtCurrentMaxLocality)
       }
       if (!launchedAnyTask) {
         taskSet.abortIfCompletelyBlacklisted(executorIdToHost.keys)