Roman Khachatryan created FLINK-23170:
-----------------------------------------

             Summary: Write metadata after materialization
                 Key: FLINK-23170
                 URL: https://issues.apache.org/jira/browse/FLINK-23170
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / State Backends
            Reporter: Roman Khachatryan
             Fix For: 1.14.0


Currently, changelog state backend writes state metadata on first state access. 
It is written to the changelog
On materialization, the changelog can be truncated, so the metadata needs to be 
written again.

This can be achieved by resetting AbstractStateChangeLogger.metaDataWritten 
flag. 
It can be further optimized by storing the SQN at which the metadata was 
written and only resetting the flag if materializedSqn >= metadataSqn; but 
materialization is relatively rare so it probably doesn't worth it.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to