tsreaper opened a new pull request, #411: URL: https://github.com/apache/flink-table-store/pull/411
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 is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
