Update SchedulerSuite.scala

apache · Jun 8, 2015 · 68e8540 · 68e8540
1 parent 4604f28
commit 68e8540
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/scheduler/SchedulerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/scheduler/SchedulerSuite.scala
@@ -36,7 +36,7 @@ class SchedulerSuite extends TestSuiteBase {
     val executors: List[String] = List("Host1", "Host2", "Host3", "Host4", "Host5")
     val locations = launcher.scheduleReceivers(receivers, executors)
     assert(locations(0)(0) === "Host1")
-    assert(locations(4)(0) === "Host5") 
+    assert(locations(4)(0) === "Host5")
     assert(locations(5)(0) === "Host1")
     assert(locations(9)(0) === "Host5")
   }
@@ -47,9 +47,9 @@ class SchedulerSuite extends TestSuiteBase {
     val executors: List[String] = List("Host1", "Host2", "Host3", "Host4", "Host5")
     val locations = launcher.scheduleReceivers(receivers, executors)
     assert(locations(0)(0) === "Host1")
-    assert(locations(2)(0) === "Host3") 
+    assert(locations(2)(0) === "Host3")
     assert(locations(0)(1) === "Host4")
-    assert(locations(1)(1) === "Host5") 
+    assert(locations(1)(1) === "Host5")
   }
 
   test("receiver scheduling - all have preferredLocation") {
@@ -58,7 +58,7 @@ class SchedulerSuite extends TestSuiteBase {
     val executors: List[String] = List("Host1", "Host5", "Host4", "Host3", "Host2")
     val locations = launcher.scheduleReceivers(receivers, executors)
     assert(locations(1)(0) === "Host2")
-    assert(locations(4)(0) === "Host5") 
+    assert(locations(4)(0) === "Host5")
   }
 
   test("receiver scheduling - some have preferredLocation") {