guozhangwang commented on pull request #8962: URL: https://github.com/apache/kafka/pull/8962#issuecomment-652701636
> * Need to write the checkpoint when recycling a standby: although we do preserve the changelog offsets when recycling a task, and should therefore write the offsets when the new task is itself closed, we do NOT write the checkpoint for uninitialized tasks. So if the new task is ultimately closed before it gets out of the CREATED state, the offsets will not be written and we can get a TaskCorruptedException If we do not gets out of the CREATED state, it means we do not call `registerStateStores` yet to load the offsets, and the existing checkpoint file has not be deleted right? ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
