hello, i am writing a spark streaming application to read data from kafka. I am using no receiver approach and enabled checkpointing to make sure I am not reading messages again in case of failure. (exactly once semantics)
i have a quick question how checkpointing needs to be configured to handle code changes in my spark streaming app. can you please suggest. hope the question makes sense. thank you regards shiv
