diff options
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/MapWithStateSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/MapWithStateSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/MapWithStateSuite.scala index b6d6585bd8..403400904b 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/MapWithStateSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/MapWithStateSuite.scala @@ -43,10 +43,10 @@ class MapWithStateSuite extends SparkFunSuite } after { + StreamingContext.getActive().foreach { _.stop(stopSparkContext = false) } if (checkpointDir != null) { Utils.deleteRecursively(checkpointDir) } - StreamingContext.getActive().foreach { _.stop(stopSparkContext = false) } } override def beforeAll(): Unit = { |