Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/20680#discussion_r170658481
--- Diff: python/pyspark/util.py ---
@@ -33,6 +34,8 @@ def _exception_message(excp):
>>> msg == _exception_message(excp)
True
"""
+ if isinstance(excp, Py4JJavaError):
--- End diff --
Maybe we need some comments to describe the workaround.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
