We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f01a967 commit f945b64Copy full SHA for f945b64
streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala
@@ -76,6 +76,9 @@ class InputStreamsSuite extends TestSuiteBase with BeforeAndAfter {
76
fail("Timeout: cannot finish all batches in 30 seconds")
77
}
78
79
+ // Ensure progress listener has been notified of all events
80
+ ssc.scheduler.listenerBus.waitUntilEmpty(500)
81
+
82
// Verify all "InputInfo"s have been reported
83
assert(ssc.progressListener.numTotalReceivedRecords === input.size)
84
assert(ssc.progressListener.numTotalProcessedRecords === input.size)
0 commit comments