[kafka] branch 2.6 updated: MINOR: Avoid WARN log message when re-init from checkpoint skipped (#8873)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.6 by this push:
     new 189bf01  MINOR: Avoid WARN log message when re-init from checkpoint skipped (#8873)
189bf01 is described below

commit 189bf0132cbecb43bda4c64f9b766f854fc87b2c
Author: Bruno Cadonna <br...@confluent.io>
AuthorDate: Mon Jun 15 19:53:27 2020 +0200

    MINOR: Avoid WARN log message when re-init from checkpoint skipped (#8873)
    
    The warning appears because the skipped offsets are not removed from the checkpoint. However, there is nothing to warn about, because the offset found there corresponding state stores and they were skipped.
    
    A. Sophie Blee-Goldman <so...@confluent.io>, Guozhang Wang <gu...@confluent.io>
---
 .../apache/kafka/streams/processor/internals/ProcessorStateManager.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
index d78c9a3..9aa682a 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
@@ -247,6 +247,7 @@ public class ProcessorStateManager implements StateManager {
                         }
                     }
                 }  else {
+                    loadedCheckpoints.remove(store.changelogPartition);
                     log.debug("Skipping re-initialization of offset from checkpoint for recycled store {}",
                               store.stateStore.name());
                 }