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)
