diff --git a/python/pyspark/streaming/tests.py b/python/pyspark/streaming/tests.py index ff5986776a94e..6a7dfd574701d 100644 --- a/python/pyspark/streaming/tests.py +++ b/python/pyspark/streaming/tests.py @@ -485,9 +485,6 @@ class TestCheckpoint(PySparkStreamingTestCase): def setUp(self): pass - def tearDown(self): - pass - def test_get_or_create(self): inputd = tempfile.mkdtemp() outputd = tempfile.mkdtemp() + "/" @@ -545,7 +542,6 @@ def check_output(n): ssc = StreamingContext.getOrCreate(cpd, setup) ssc.start() check_output(3) - ssc.stop(True, True) if __name__ == "__main__":