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

Posted to dev@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/28 17:35:00 UTC

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

Yun Gao created FLINK-26403:
-------------------------------

             Summary: 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


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)