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

Reply via email to