[ https://issues.apache.org/jira/browse/FLINK-30573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Caizhi Weng closed FLINK-30573. ------------------------------- Resolution: Fixed master: 8fdbbd4e8c22a82d79509cab0add4a6aa7331672 release-0.3: 1ba8f372a05d64e7370f7dcbb65b77e23079f8ef > 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 > Priority: Major > Labels: pull-request-available > 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)