zoltar9264 commented on code in PR #22669:
URL: https://github.com/apache/flink/pull/22669#discussion_r1243246177
##########
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java:
##########
@@ -728,6 +731,7 @@ private ChangelogSnapshotState completeRestore(
materializationId = Math.max(materializationId,
h.getMaterializationID());
}
}
+ this.lastFailedMaterializationId = materializationId;
Review Comment:
Sorry, this is my mistake. I originally wanted to set
`lastConfirmedMaterializationId` to "restore" `materializationId` so that the
first materialization can be triggered. (Or we can add a field to save the id
of the first materialization, and check whether it is the first materialization
when `initMaterialization`.)
--
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.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
