[ 
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)

Reply via email to