Fix style issues and small type in StreamingListenerSuite

apache · May 24, 2015 · 6453c90 · 6453c90
1 parent e8506d4
commit 6453c90
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala
@@ -146,10 +146,10 @@ class StreamingListenerSuite extends TestSuiteBase with Matchers {
         classOf[ReceiverInfoCollector].getName)
     val scc = new StreamingContext(conf, Seconds(1))
 
-    scc.scheduler.listenerBus.listeners.collect { case x: BatchInfoCollector => x}.size should be (1)
     scc.scheduler.listenerBus.listeners.collect {
-      case x: ReceiverInfoCollector =>
-    }.size should be (1)
+      case x: BatchInfoCollector => x }.size should be (1)
+    scc.scheduler.listenerBus.listeners.collect {
+      case x: ReceiverInfoCollector => x }.size should be (1)
   }
 }