Increase receiverInfo collector timeout to 2 secs

apache · Jan 14, 2015 · 868efab · 868efab
1 parent 3118e5e
commit 868efab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala
@@ -73,7 +73,7 @@ class StreamingListenerSuite extends TestSuiteBase with Matchers {
 
     ssc.start()
     try {
-      eventually(timeout(1000 millis), interval(20 millis)) {
+      eventually(timeout(2000 millis), interval(20 millis)) {
         collector.startedReceiverStreamIds.size should equal (1)
         collector.startedReceiverStreamIds(0) should equal (0)
         collector.stoppedReceiverStreamIds should have size 1