Skip to content

Commit 3118e5e

Browse files
committed
Fix StreamingListenerSuite's startedReceiverStreamIds size
1 parent 634abde commit 3118e5e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ class StreamingListenerSuite extends TestSuiteBase with Matchers {
7474
ssc.start()
7575
try {
7676
eventually(timeout(1000 millis), interval(20 millis)) {
77-
collector.startedReceiverStreamIds.size should be >= 1
77+
collector.startedReceiverStreamIds.size should equal (1)
7878
collector.startedReceiverStreamIds(0) should equal (0)
7979
collector.stoppedReceiverStreamIds should have size 1
8080
collector.stoppedReceiverStreamIds(0) should equal (0)

0 commit comments

Comments
 (0)