Fix style issues

shivaram · Feb 12, 2015 · 34d0283 · 34d0283
1 parent 3b464b7
commit 34d0283
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/MapOutputTracker.scala b/core/src/main/scala/org/apache/spark/MapOutputTracker.scala
@@ -301,7 +301,10 @@ private[spark] class MapOutputTrackerMaster(conf: SparkConf)
   // of (location, size) of map outputs.
   //
   // This method is not thread-safe
-  def getStatusByReducer(shuffleId: Int, numReducers: Int): Option[Map[Int, Array[(BlockManagerId, Long)]]] = {
+  def getStatusByReducer(
+      shuffleId: Int,
+      numReducers: Int)
+    : Option[Map[Int, Array[(BlockManagerId, Long)]]] = {
     if (!statusByReducer.contains(shuffleId) && mapStatuses.contains(shuffleId)) {
       val statuses = mapStatuses(shuffleId)
       if (statuses.length > 0) {

diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1339,8 +1339,9 @@ class DAGScheduler(
             // Get the map output locations for this reducer
             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
+              val topLocs = CollectionUtils.takeOrdered(
+                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))
             }
           }