DOJI45 commented on a change in pull request #9247:
URL: https://github.com/apache/kafka/pull/9247#discussion_r487431637
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##########
@@ -332,6 +332,15 @@ public void resume() {
case SUSPENDED:
// just transit the state without any logical changes:
suspended and restoring states
// are not actually any different for inner modules
+
+ // Deleting checkpoint file before transition to RESTORING
state (KAFKA-10362)
+ try {
+ stateMgr.deleteCheckPointFile();
+ log.debug("Deleted check point file");
Review comment:
I will change the log message
----------------------------------------------------------------
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
