Skip to content

Commit 1d84142

Browse files
committed
remove unimplement test
1 parent f0ea311 commit 1d84142

File tree

1 file changed

+1
-18
lines changed

1 file changed

+1
-18
lines changed

python/pyspark/streaming_tests.py

Lines changed: 1 addition & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -449,22 +449,5 @@ def _run_stream(self, test_input, test_func, expected_output, numSlices=None):
449449

450450
return result
451451

452-
#TODO: add testcase for saveAs*
453-
454-
455-
class TestSaveAsFilesSuite(PySparkStreamingTestCase):
456-
def setUp(self):
457-
PySparkStreamingTestCase.setUp(self)
458-
self.timeout = 10 # seconds
459-
self.numInputPartitions = 2
460-
461-
def tearDown(self):
462-
PySparkStreamingTestCase.tearDown(self)
463-
464-
@classmethod
465-
def tearDownClass(cls):
466-
PySparkStreamingTestCase.tearDownClass()
467-
468-
469452
if __name__ == "__main__":
470-
unittest.main(verbosity=2)
453+
unittest.main()

0 commit comments

Comments
 (0)