diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala index 2aa5e0876b6e..66ef969e965d 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala @@ -434,7 +434,8 @@ package object testPackage extends Assertions { assert(rddGenerated && foreachCallSiteCorrect, "Call site in foreachRDD was not correct") } } finally { - ssc.stop() + ssc.awaitTermination(500) + ssc.stop(stopSparkContext = true, stopGracefully = true) } } }