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 8b26397 commit 7d998a3Copy full SHA for 7d998a3
streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala
@@ -313,7 +313,6 @@ class StreamingContextSuite extends SparkFunSuite with BeforeAndAfter with Timeo
313
val streamingSource = StreamingContextSuite.getStreamingSource(ssc)
314
assert(sources.contains(streamingSource))
315
assert(ssc.getState() === StreamingContextState.ACTIVE)
316
- Thread.sleep(100)
317
318
ssc.stop()
319
val sourcesAfterStop = StreamingContextSuite.getSources(ssc.env.metricsSystem)
0 commit comments