Fabian Paul created FLINK-26304:
-----------------------------------
Summary: GlobalCommitter can receive failed committables
Key: FLINK-26304
URL: https://issues.apache.org/jira/browse/FLINK-26304
Project: Flink
Issue Type: Bug
Components: API / DataStream, Connectors / Common
Affects Versions: 1.14.3
Reporter: Fabian Paul
Fix For: 1.14.4
After the introduction of retrying failed committables in the committer, it is
important to only forward committables that have been committed to the
GlobalCommitter. Currently, this is ignored and the Committer will forward all
committable nevertheless if they succeeded.
[1]
https://github.com/apache/flink/blob/0a76d632f33d9a69df87457a63043bd7f609ed40/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractStreamingCommitterHandler.java#L144
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
