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. 

Connect with Databricks Users in Your Area

Join a Regional User Group to connect with local Databricks users. Events will be happening in your city, and you wonโ€™t want to miss the chance to attend and share knowledge.

If there isnโ€™t a group near you, start one and help create a community that brings people together.

Request a New Group