We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 491d3fc commit 4153b02Copy full SHA for 4153b02
python/pyspark/tests.py
@@ -879,7 +879,8 @@ def test_pipe_functions(self):
879
rdd = self.sc.parallelize(data)
880
with QuietTest(self.sc):
881
self.assertRaises(Py4JJavaError, rdd.pipe('cc').collect)
882
- result = rdd.pipe('cat').collect().sort()
+ result = rdd.pipe('cat').collect()
883
+ result.sort()
884
[self.assertEqual(x, y) for x, y in zip(data, result)]
885
886
0 commit comments