Skip to content

Commit 2457883

Browse files
Try this as a python fix
Spark commit apache/spark@52dfa3d#diff-0a22271fecb7c4a38d8afe18ac8676546f1ad8fd221ccc0a5e4cfacdee869298 But could also be related to apache/spark@3b4c423#diff-0a22271fecb7c4a38d8afe18ac8676546f1ad8fd221ccc0a5e4cfacdee869298 which adds self.log_exception() which is what is throwing the exception
1 parent 344ca12 commit 2457883

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/delta/exceptions.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ def _patch_convert_exception() -> None:
151151
Patch PySpark's exception convert method to convert Delta's Scala concurrent exceptions to the
152152
corresponding Python exceptions.
153153
"""
154-
original_convert_sql_exception = captured.convert_exception
154+
original_convert_sql_exception = captured._convert_exception
155155

156156
def convert_delta_exception(e: "JavaObject") -> CapturedException:
157157
delta_exception = _convert_delta_exception(e)

0 commit comments

Comments
 (0)