mjsax commented on a change in pull request #8886:
URL: https://github.com/apache/kafka/pull/8886#discussion_r441813661
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##########
@@ -85,6 +85,21 @@ public void initializeMetadata() {}
public boolean initializeStateStores() {
log.trace("Initializing state stores");
registerStateStores();
+
+ if (eosEnabled) {
+ final Set<TopicPartition> partitionsToReinitialize = new
HashSet<>();
+ for (final TopicPartition partition :
stateMgr.checkpointed().keySet()) {
Review comment:
Yeah, the fix is mainly for illustrating purpose atm. The problem is
really, that the checkpoint file get's deleted for EOS before we reach this
point in the code and thus we need to "hack" around it -- it would be cleaner
if we could just check if a checkpoint exists of not...
----------------------------------------------------------------
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
