You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2022/03/01 09:55:00 UTC

[jira] [Updated] (FLINK-26403) SinkWriter should emit all the pending committables on endOfInput

     [ https://issues.apache.org/jira/browse/FLINK-26403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

ASF GitHub Bot updated FLINK-26403:
-----------------------------------
    Labels: pull-request-available  (was: )

> SinkWriter should emit all the pending committables on endOfInput
> -----------------------------------------------------------------
>
>                 Key: FLINK-26403
>                 URL: https://issues.apache.org/jira/browse/FLINK-26403
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Core
>    Affects Versions: 1.15.0
>            Reporter: Yun Gao
>            Assignee: Gen Luo
>            Priority: Blocker
>              Labels: pull-request-available
>
> Currently the SinkWriterOperator not drained all the pending committables on endOfInput() and left them till final checkpoint, which would be in fact deserted. This might cause data loss or the CommitterOperator hanged on endOfInput() due to not received expected number of committables.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)