Jingsong Lee created FLINK-26293:
------------------------------------

             Summary: Store log offsets in snapshot
                 Key: FLINK-26293
                 URL: https://issues.apache.org/jira/browse/FLINK-26293
             Project: Flink
          Issue Type: Sub-task
          Components: Table Store
            Reporter: Jingsong Lee
             Fix For: table-store-0.1.0


Now we have put logOffsets inside ManifestCommittable, but it is not saved when 
generating snapshot in FileStoreCommitImpl.
We need to save the logOffsets in the snapshot and some additional processing 
is required:

When logOffsets does not contain all buckets, it means that the current 
generated snapshot does not write data to all buckets, and we should read the 
last snapshot to complete the bucket's offsets.



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

Reply via email to