Fix build

apache · Mar 16, 2017 · d4979e3 · d4979e3
1 parent f96ec68
commit d4979e3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
@@ -443,8 +443,8 @@ class DAGSchedulerSuite extends SparkFunSuite with LocalSparkContext with Timeou
         null)
     ))
 
-    // Here is the main assertion -- make sure that we de-register the map outputs for both map stage
-    // from both executors on hostA
+    // Here is the main assertion -- make sure that we de-register
+    // the map outputs for both map stage from both executors on hostA
     val mapStatus1 = mapOutputTracker.mapStatuses.get(0).get
     assert(mapStatus1.count(_ != null) === 1)
     assert(mapStatus1(2).location.executorId === "exec-hostB")