[FLINK-24371] Support SinkWriter preCommit without the need of a committer

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.0, 1.15.0
• Fix Version/s: 1.14.3, 1.15.0
• Component/s: API / DataStream, Connectors / Common
• Labels: pull-request-available
• Assignee: Fabian Paul
• Reporter: Fabian Paul
• Created: 24/Sep/21 10:39
• Updated: 15/Dec/21 01:44
• Resolved: 28/Sep/21 13:27

Description

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.

Issue Links

• links to: GitHub Pull Request #17351
• links to: GitHub Pull Request #17364