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)
