cancel
Showing results for 
Search instead for 
Did you mean: 
Data Engineering
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. 

Welcome to Databricks Community: Lets learn, network and celebrate together

Join our fast-growing data practitioner and expert community of 80K+ members, ready to discover, help and collaborate together while making meaningful connections. 

Click here to register and join today! 

Engage in exciting technical discussions, join a group with your peers and meet our Featured Members.