diff --git a/python/pyspark/streaming_tests.py b/python/pyspark/streaming_tests.py index ba6c028f1fb55..067b168e2b528 100644 --- a/python/pyspark/streaming_tests.py +++ b/python/pyspark/streaming_tests.py @@ -449,22 +449,5 @@ def _run_stream(self, test_input, test_func, expected_output, numSlices=None): return result -#TODO: add testcase for saveAs* - - -class TestSaveAsFilesSuite(PySparkStreamingTestCase): - def setUp(self): - PySparkStreamingTestCase.setUp(self) - self.timeout = 10 # seconds - self.numInputPartitions = 2 - - def tearDown(self): - PySparkStreamingTestCase.tearDown(self) - - @classmethod - def tearDownClass(cls): - PySparkStreamingTestCase.tearDownClass() - - if __name__ == "__main__": - unittest.main(verbosity=2) + unittest.main()