Skip to content

Commit 643b59d

Browse files
committed
Revert unnecessary change
1 parent 150e58c commit 643b59d

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

python/pyspark/streaming/tests.py

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1108,11 +1108,4 @@ def search_kinesis_asl_assembly_jar():
11081108
jars = "%s,%s,%s" % (kafka_assembly_jar, flume_assembly_jar, kinesis_asl_assembly_jar)
11091109

11101110
os.environ["PYSPARK_SUBMIT_ARGS"] = "--jars %s pyspark-shell" % jars
1111-
#unittest.main()
1112-
1113-
suite = unittest.TestSuite()
1114-
suite.addTest(StreamingContextTests('test_get_active'))
1115-
suite.addTest(StreamingContextTests('test_get_active_or_create'))
1116-
suite.addTest(CheckpointTests('test_get_or_create_and_get_active_or_create'))
1117-
1118-
unittest.TextTestRunner(verbosity=2).run(suite)
1111+
unittest.main()

0 commit comments

Comments
 (0)