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

Reply via email to