[FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.19.0
• Labels: pull-request-available

Release Note

According to FLIP-372 (https://cwiki.apache.org/confluence/display/FLINK/FLIP-372%3A+Enhance+and+synchronize+Sink+API+to+match+the+Source+API) the SinkV2 API has been changed.

The following interfaces are deprecated: TwoPhaseCommittingSink, StatefulSink, WithPreWriteTopology, WithPreCommitTopology, WithPostCommitTopology.

The following new interfaces has been introduced: CommitterInitContext, CommittingSinkWriter, WriterInitContext, StatefulSinkWriter.

The following interface method's parameter has been changed: Sink.createWriter

The original interfaces will remain available during the 1.19 release line, but they will be removed in consecutive releases. For the changes required when migrating, please consult the Migration Plan detailed in the FLIP

• Assignee: Peter Vary
• Reporter: Peter Vary
• Created: 03/Jan/24 12:08
• Updated: 20/Feb/24 14:52
• Resolved: 12/Jan/24 09:16

Description

Create the new interfaces, set inheritance and deprecation to finalize the interface.
After this change the new interafaces will exits, but they will not be functional.

The existing interfaces, and test should be working without issue, to verify that adding the API will be backward compatible.

Issue Links

• links to: GitHub Pull Request #24022
• links to: GitHub Pull Request #24080