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)