Hubert-Dudek
Databricks MVP

If you need checkpointing, please try the below code. Thanks to persist, you will avoid reprocessing:

df = ps.sql(sql).persist()
df.spark.checkpoint()


My blog: https://databrickster.medium.com/

View solution in original post