diff --git a/python/pyspark/tests.py b/python/pyspark/tests.py index aba5606ab71b7..9e5095734a075 100644 --- a/python/pyspark/tests.py +++ b/python/pyspark/tests.py @@ -877,7 +877,8 @@ def test_sortByKey_uses_all_partitions_not_only_first_and_last(self): def test_pipe_functions(self): data = ['1', '2', '3'] rdd = self.sc.parallelize(data) - self.assertRaises(Exception, rdd.pipe('cc').collect()) + with QuietTest(self.sc): + self.assertRaises(Exception, rdd.pipe('cc').collect()) result = rdd.pipe('cat').collect().sort() [self.assertEqual(x, y) for x, y in zip(data, result)]