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 2021/09/24 10:40:00 UTC

[jira] [Created] (FLINK-24371) Support SinkWriter preCommit without the need of a committer

Fabian Paul created FLINK-24371:
-----------------------------------

             Summary: Support SinkWriter preCommit without the need of a committer
                 Key: FLINK-24371
                 URL: https://issues.apache.org/jira/browse/FLINK-24371
             Project: Flink
          Issue Type: Bug
          Components: API / DataStream, Connectors / Common
    Affects Versions: 1.14.0, 1.15.0
            Reporter: Fabian Paul


For some sinks i.e. elasticsearch we only want to listen for the snapshot barrier once retrieved the sink flushes the buffered records.
These sinks do not snapshot any state thus do not implement the `snapshotState()` method. 

We already have a NoopCommitHandler which swallows the passed committables but it should at least call `preCommit()` on the SinkWriter.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)