[ https://issues.apache.org/jira/browse/FLINK-32901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Feifan Wang updated FLINK-32901: -------------------------------- Component/s: Runtime / Checkpointing Runtime / State Backends Description: The current StateChangelogWriter lacks an interface to set the initial sequence number, and FsStateChangelogWriter always sets the initial sequence number to 0. This causes the first materialization after recovery from the retained checkpoint to be delayed. Summary: Should set initial initialSequenceNumber of StateChangelogWriter after restore (was: Should set initial) > Should set initial initialSequenceNumber of StateChangelogWriter after restore > ------------------------------------------------------------------------------ > > Key: FLINK-32901 > URL: https://issues.apache.org/jira/browse/FLINK-32901 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing, Runtime / State Backends > Reporter: Feifan Wang > Priority: Critical > > The current StateChangelogWriter lacks an interface to set the initial > sequence number, and FsStateChangelogWriter always sets the initial sequence > number to 0. This causes the first materialization after recovery from the > retained checkpoint to be delayed. -- This message was sent by Atlassian Jira (v8.20.10#820010)