Github user icexelloss commented on a diff in the pull request:
https://github.com/apache/spark/pull/21467#discussion_r192424377
--- Diff: python/pyspark/tests.py ---
@@ -1303,11 +1303,13 @@ def stopit(*x):
self.assertRaises(Py4JJavaError, seq_rdd.filter(stopit).collect)
self.assertRaises(Py4JJavaError,
seq_rdd.cartesian(seq_rdd).flatMap(stopit).collect)
self.assertRaises(Py4JJavaError, seq_rdd.foreach, stopit)
- self.assertRaises(Py4JJavaError, keyed_rdd.reduceByKeyLocally,
stopit)
self.assertRaises(Py4JJavaError, seq_rdd.reduce, stopit)
self.assertRaises(Py4JJavaError, seq_rdd.fold, 0, stopit)
+ self.assertRaises(Py4JJavaError, seq_rdd.foreach, stopit)
--- End diff --
Sorry for the late comment, can you also change these tests to check error
message using assertRaisesRegexp?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
