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