Hangxiang Yu created FLINK-34652:
------------------------------------

             Summary: Use CheckpointStreamFactory for StateChangeFsUploader
                 Key: FLINK-34652
                 URL: https://issues.apache.org/jira/browse/FLINK-34652
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Checkpointing
            Reporter: Hangxiang Yu


As discussed before, we may consider supporting CheckpointStreamFactory for 
StateChangeFsUploader:
 * need for checkpointId in the current API to resolve the location
 * 
different settings for materialized/changelog (e.g. timeouts)
 * 
re-use closeAndGetHandle
 * 
re-use in-memory handles (.metadata)
 * 
handle in-memory handles duplication

It could be considered together with FLINK-32085



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to