You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/22 08:15:00 UTC

[jira] [Created] (FLINK-26293) Store log offsets in snapshot

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)