[jira] [Commented] (FLINK-25261) Changelog not truncated on materialization

["Yuan Mei (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468413#comment-17468413 ] 

Yuan Mei commented on FLINK-25261:
----------------------------------

Upon offline discussion, there are two more questions/problems related. I will extract them and open a separate ticket, and discuss whether/how to handle them before 1.15.

For truncation upon materialization, it is wrapped in the mailbox, so it should work fine regarding the race condition mentioned above. It does not block checkpoint snapshots as well, because what to upload/not upload is decided in the task thread fairly fast; while the real uploading is done asycnously.

> Changelog not truncated on materialization
> ------------------------------------------
>
>                 Key: FLINK-25261
>                 URL: https://issues.apache.org/jira/browse/FLINK-25261
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / State Backends
>    Affects Versions: 1.15.0
>            Reporter: Roman Khachatryan
>            Assignee: Roman Khachatryan
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.15.0
>
>
> [https://github.com/apache/flink/blob/dcc4d43e413b20f70036e73c61d52e2e1c5afee7/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java#L640]



--
This message was sent by Atlassian Jira
(v8.20.1#820001)