MINOR: Avoid WARN log message when re-init from checkpoint skipped
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 Guozhang Wang
@@ -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());
}
