[
https://issues.apache.org/jira/browse/FLINK-26403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-26403:
-------------------------------
Assignee: Gen Luo
> 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
>
> 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)
