We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 11d6f09 commit f4cae6cCopy full SHA for f4cae6c
python/pyspark/sql/utils.py
@@ -45,7 +45,8 @@ def deco(*a, **kw):
45
return f(*a, **kw)
46
except py4j.protocol.Py4JJavaError as e:
47
s = e.java_exception.toString()
48
- stackTrace = '\n\t at'.join(map(lambda x: x.toString(), e.java_exception.getStackTrace()))
+ stackTrace = '\n\t at'.join(map(lambda x: x.toString(),
49
+ e.java_exception.getStackTrace()))
50
if s.startswith('org.apache.spark.sql.AnalysisException: '):
51
raise AnalysisException(s.split(': ', 1)[1], stackTrace)
52
if s.startswith('java.lang.IllegalArgumentException: '):
0 commit comments