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

Posted to dev@flink.apache.org by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/22 15:51:00 UTC

[jira] [Created] (FLINK-26304) GlobalCommitter can receive failed committables

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)