pyspark.sql.streaming.StreamingQueryManager.resetTerminated¶
-
StreamingQueryManager.
resetTerminated
() → None[source]¶ Forget about past terminated queries so that
awaitAnyTermination()
can be used again to wait for new terminations.New in version 2.0.0.
Changed in version 3.5.0: Supports Spark Connect.
Examples
>>> spark.streams.resetTerminated()