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 8c8768f50b..9ddaf78acf 100644 --- a/python/pyspark/sql/utils.py +++ b/python/pyspark/sql/utils.py @@ -71,7 +71,7 @@ def capture_sql_exception(f): raise AnalysisException(s.split(': ', 1)[1], stackTrace) if s.startswith('org.apache.spark.sql.catalyst.parser.ParseException: '): raise ParseException(s.split(': ', 1)[1], stackTrace) - if s.startswith('org.apache.spark.sql.ContinuousQueryException: '): + if s.startswith('org.apache.spark.sql.streaming.ContinuousQueryException: '): raise ContinuousQueryException(s.split(': ', 1)[1], stackTrace) if s.startswith('org.apache.spark.sql.execution.QueryExecutionException: '): raise QueryExecutionException(s.split(': ', 1)[1], stackTrace) |