PySparkException([message, error_class, …])
PySparkException
Base Exception for handling errors generated from PySpark.
AnalysisException([message, error_class, …])
AnalysisException
Failed to analyze a SQL query plan.
TempTableAlreadyExistsException([message, …])
TempTableAlreadyExistsException
Failed to create temp view since it is already exists.
ParseException([message, error_class, …])
ParseException
Failed to parse a SQL command.
IllegalArgumentException([message, …])
IllegalArgumentException
Passed an illegal or inappropriate argument.
StreamingQueryException([message, …])
StreamingQueryException
Exception that stopped a StreamingQuery.
StreamingQuery
QueryExecutionException([message, …])
QueryExecutionException
Failed to execute a query.
PythonException([message, error_class, …])
PythonException
Exceptions thrown from Python workers.
UnknownException([message, error_class, …])
UnknownException
None of the above exceptions.
SparkUpgradeException([message, …])
SparkUpgradeException
Exception thrown because of Spark upgrade.
PySparkException.getErrorClass()
PySparkException.getErrorClass
Returns an error class as a string.
PySparkException.getMessageParameters()
PySparkException.getMessageParameters
Returns a message parameters as a dictionary.
PySparkException.getSqlState()
PySparkException.getSqlState
Returns an SQLSTATE as a string.