Fix style

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

@@ -138,7 +138,7 @@ class DAGScheduler(
   taskScheduler.setDAGScheduler(this)
 
   // Number of map, reduce tasks above which we do not assign preferred locations
-  // based on map output sizes. We limit the size of jobs for which assign preferred locations 
+  // based on map output sizes. We limit the size of jobs for which assign preferred locations
   // as sorting the locations by size becomes expensive.
   private[this] val SHUFFLE_PREF_MAP_THRESHOLD = 1000
   // NOTE: This should be less than 2000 as we use HighlyCompressedMapStatus beyond that
@@ -1411,8 +1411,8 @@ class DAGScheduler(
         if (rdd.partitions.size < SHUFFLE_PREF_REDUCE_THRESHOLD &&
             s.rdd.partitions.size < SHUFFLE_PREF_MAP_THRESHOLD) {
           // Get the preferred map output locations for this reducer
-          val topLocsForReducer = mapOutputTracker.getLocationsWithLargestOutputs(s.shuffleId, partition,
-            rdd.partitions.size, NUM_REDUCER_PREF_LOCS)
+          val topLocsForReducer = mapOutputTracker.getLocationsWithLargestOutputs(s.shuffleId,
+            partition, rdd.partitions.size, NUM_REDUCER_PREF_LOCS)
           if (topLocsForReducer.nonEmpty) {
             return topLocsForReducer.get.map(loc => TaskLocation(loc.host, loc.executorId))
           }