Fix bug introduced by line length adjustment

shivaram · Feb 13, 2015 · 774751b · 774751b
1 parent 34d0283
commit 774751b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1340,8 +1340,8 @@ class DAGScheduler(
             if (status.contains(partition)) {
               // Select first few locations as preferred locations for the reducer
               val topLocs = CollectionUtils.takeOrdered(
-                status(partition).iterator, NUM_REDUCER_PREF_LOCS)
-                  (Ordering.by[(BlockManagerId, Long), Long](_._2).reverse).toSeq
+                status(partition).iterator, NUM_REDUCER_PREF_LOCS)(
+                  Ordering.by[(BlockManagerId, Long), Long](_._2).reverse).toSeq
               return topLocs.map(_._1).map(loc => TaskLocation(loc.host, loc.executorId))
             }
           }