cancel
Showing results for 
Search instead for 
Did you mean: 
Data Engineering
Join discussions on data engineering best practices, architectures, and optimization strategies within the Databricks Community. Exchange insights and solutions with fellow data engineers.
cancel
Showing results for 
Search instead for 
Did you mean: 

Question about notifications and failed jobs

f1nesse13
New Contributor

Hello, I had a question involving rerunning a job from a checkpoint using ‘Repair Run’. I have a job which failed and Im looking to rerun the stream from a checkpoint. My job uses notifications for file detection (cloudFiles.useNotifications). My question is will the messages in the queue be consumed if Im rerunning from that checkpoint.

1 REPLY 1

BigRoux
Databricks Employee
Databricks Employee

When rerunning your job from a checkpoint using Repair Run with cloudFiles.useNotifications, only unprocessed messages in the queue (representing new or failed-to-process files) will be consumed. Files or events already recorded in the checkpoint will not trigger reprocessing unless you reset or delete the checkpoint metadata.

Hope this helps.

Louis.