Skip to content

Commit

Permalink
remove unimplement test
Browse files Browse the repository at this point in the history
  • Loading branch information
giwa committed Aug 21, 2014
1 parent f0ea311 commit 1d84142
Showing 1 changed file with 1 addition and 18 deletions.
19 changes: 1 addition & 18 deletions python/pyspark/streaming_tests.py
Original file line number Diff line number Diff line change
Expand Up @@ -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()

0 comments on commit 1d84142

Please sign in to comment.