[ https://issues.apache.org/jira/browse/FLINK-30207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee closed FLINK-30207. -------------------------------- Resolution: Fixed master: 23dad789879735249651992ab9fe23b986ef1564 > 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 > Priority: Major > Labels: pull-request-available > 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)