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

Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/03 03:43:00 UTC

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17500482#comment-17500482 ] 

Yun Gao commented on FLINK-26403:
---------------------------------

Fix on master via 2c9d64e34cfd3025c87c1d3bbd2d1b596df11691.

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