Skip to content

Commit 5082d28

Browse files
committed
Fix the syntax error for Python 2.6
1 parent fca416b commit 5082d28

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/pyspark/streaming/tests.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -937,7 +937,7 @@ def get_output(_, rdd):
937937
self.ssc.start()
938938

939939
testData = [i for i in range(1, 11)]
940-
expectedOutput = {str(i) for i in testData}
940+
expectedOutput = set([str(i) for i in testData])
941941
start_time = time.time()
942942
while time.time() - start_time < 120:
943943
kinesisTestUtils.pushData(testData)

0 commit comments

Comments
 (0)