Errors

Classes

PySparkException([message, error_class, …])

Base Exception for handling errors generated from PySpark.

AnalysisException([message, error_class, …])

Failed to analyze a SQL query plan.

TempTableAlreadyExistsException([message, …])

Failed to create temp view since it is already exists.

ParseException([message, error_class, …])

Failed to parse a SQL command.

IllegalArgumentException([message, …])

Passed an illegal or inappropriate argument.

StreamingQueryException([message, …])

Exception that stopped a StreamingQuery.

QueryExecutionException([message, …])

Failed to execute a query.

PythonException([message, error_class, …])

Exceptions thrown from Python workers.

UnknownException([message, error_class, …])

None of the above exceptions.

SparkUpgradeException([message, …])

Exception thrown because of Spark upgrade.

Methods

PySparkException.getErrorClass()

Returns an error class as a string.

PySparkException.getMessageParameters()

Returns a message parameters as a dictionary.

PySparkException.getSqlState()

Returns an SQLSTATE as a string.