diff --git a/python/pyspark/errors/exceptions/captured.py b/python/pyspark/errors/exceptions/captured.py index 687bdec14154e..e78a7c7bce8a8 100644 --- a/python/pyspark/errors/exceptions/captured.py +++ b/python/pyspark/errors/exceptions/captured.py @@ -59,6 +59,8 @@ def __init__( ) self._desc = desc if desc is not None else cast(Py4JJavaError, origin).getMessage() + if self._desc is None: + self._desc = "" assert SparkContext._jvm is not None self._stackTrace = ( stackTrace