diff options
Diffstat (limited to 'python/pyspark/sql/utils.py')
| -rw-r--r-- | python/pyspark/sql/utils.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/sql/utils.py b/python/pyspark/sql/utils.py index b89ea8c6e0..7ea0e0d5c9 100644 --- a/python/pyspark/sql/utils.py +++ b/python/pyspark/sql/utils.py @@ -55,7 +55,7 @@ def capture_sql_exception(f): e.java_exception.getStackTrace())) if s.startswith('org.apache.spark.sql.AnalysisException: '): raise AnalysisException(s.split(': ', 1)[1], stackTrace) - if s.startswith('org.apache.spark.sql.catalyst.parser.ng.ParseException: '): + if s.startswith('org.apache.spark.sql.catalyst.parser.ParseException: '): raise ParseException(s.split(': ', 1)[1], stackTrace) if s.startswith('java.lang.IllegalArgumentException: '): raise IllegalArgumentException(s.split(': ', 1)[1], stackTrace) |