-
- Downloads
[STREAMING][TEST] Fix flaky streaming.FailureSuite
Under some corner cases, the test suite failed to shutdown the SparkContext causing cascaded failures. This fix does two things - Makes sure no SparkContext is active after every test - Makes sure StreamingContext is always shutdown (prevents leaking of StreamingContexts as well, just in case) Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #11166 from tdas/fix-failuresuite.
Showing
- streaming/src/test/scala/org/apache/spark/streaming/FailureSuite.scala 4 additions, 1 deletion.../test/scala/org/apache/spark/streaming/FailureSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/MasterFailureTest.scala 2 additions, 1 deletion.../scala/org/apache/spark/streaming/MasterFailureTest.scala
Loading
Please register or sign in to comment