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 8071541 commit be5e5ffCopy full SHA for be5e5ff
python/pyspark/streaming/tests.py
@@ -485,9 +485,6 @@ class TestCheckpoint(PySparkStreamingTestCase):
485
def setUp(self):
486
pass
487
488
- def tearDown(self):
489
- pass
490
-
491
def test_get_or_create(self):
492
inputd = tempfile.mkdtemp()
493
outputd = tempfile.mkdtemp() + "/"
@@ -545,7 +542,6 @@ def check_output(n):
545
542
ssc = StreamingContext.getOrCreate(cpd, setup)
546
543
ssc.start()
547
544
check_output(3)
548
- ssc.stop(True, True)
549
550
551
if __name__ == "__main__":
0 commit comments