pyspark.sql.streaming.StreamingQuery.exception¶

StreamingQuery.exception() → Optional[pyspark.errors.exceptions.base.StreamingQueryException][source]¶

New in version 2.1.0.

Returns

StreamingQueryException: the StreamingQueryException if the query was terminated by an exception, or None.

pyspark.sql.streaming.StreamingQuery.awaitTermination pyspark.sql.streaming.StreamingQuery.explain