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: 

Can we reuse checkpoints in Spark Streaming?

Constantine
Contributor III

I am reading data from a Kafka topic, say topic_a.

I have an application, app_one which uses Spark Streaming to read data from topic_a. I have a checkpoint location, loc_a to store the checkpoint.

Now, app_one has read data till offset 90.

Can I create a new notebook, say app_two and then copy the checkpoint folder and point the app_two to this copied checkpoint folder. Will this start reading from offset 90?

1 ACCEPTED SOLUTION

Accepted Solutions

jose_gonzalez
Moderator
Moderator

Hi @John Constantine​,

Is not recommended to share the checkpoint with your queries. Every streaming query should have their own checkpoint. If you can to start at the offset 90 in another query, then you can define it when starting your job. You can mentioned that you want your query to start processing at a customer offset. 

View solution in original post

1 REPLY 1

jose_gonzalez
Moderator
Moderator

Hi @John Constantine​,

Is not recommended to share the checkpoint with your queries. Every streaming query should have their own checkpoint. If you can to start at the offset 90 in another query, then you can define it when starting your job. You can mentioned that you want your query to start processing at a customer offset. 

Join 100K+ Data Experts: Register Now & Grow with Us!

Excited to expand your horizons with us? Click here to Register and begin your journey to success!

Already a member? Login and join your local regional user group! If there isn’t one near you, fill out this form and we’ll create one for you to join!