[
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)