From 774751bb08cab26ea2eaf233d466c3509103dc98 Mon Sep 17 00:00:00 2001 From: Shivaram Venkataraman Date: Thu, 12 Feb 2015 16:01:39 -0800 Subject: [PATCH] Fix bug introduced by line length adjustment --- .../main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 4 ++-- 1 file changed, 2 insertions(+), 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 index fb7ffca0ceadb..6716aae9be6d5 100644 --- 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)) } }