Caizhi Weng created FLINK-30207:
-----------------------------------
Summary: Move split initialization and discovery logic fully into
SnapshotEnumerator in Table Store
Key: FLINK-30207
URL: https://issues.apache.org/jira/browse/FLINK-30207
Project: Flink
Issue Type: Sub-task
Components: Table Store
Affects Versions: table-store-0.3.0
Reporter: Caizhi Weng
Assignee: Caizhi Weng
Fix For: table-store-0.3.0
It is possible that the separated compact job is started long after the write
jobs. so compact job sources need a special split initialization logic: we will
find the latest COMPACT snapshot, and start compacting right after this
snapshot.
However, split initialization logic are currently coded into
{{FileStoreSource}}. We should extract these logic into {{SnapshotEnumerator}}
so that we can create our special {{SnapshotEnumerator}} for compact sources.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
