Caizhi Weng created FLINK-30573:
-----------------------------------
Summary: Table Store dedicated compact job may skip some records
when checkpoint interval is long
Key: FLINK-30573
URL: https://issues.apache.org/jira/browse/FLINK-30573
Project: Flink
Issue Type: Bug
Components: Table Store
Affects Versions: table-store-0.3.0, table-store-0.4.0
Reporter: Caizhi Weng
Assignee: Caizhi Weng
Fix For: table-store-0.3.0, table-store-0.4.0
Currently the sink for Table Store dedicated compact job only receives records
about what buckets are changed, instead of what files are changed. If the
writer is kept open, new files of this bucket may be skipped.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
