[FLINK-36245] Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0

• Type: Technical Debt
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0-preview
• Component/s: Connectors / Common
• Labels: 2.0-related pull-request-available
• Assignee: Yanquan Lv
• Reporter: Qingsheng Ren
• Created: 10/Sep/24 04:25
• Updated: 29/Oct/24 12:17
• Resolved: 30/Sep/24 08:02

Description

SourceFunction, SinkFunction and Sink V1 API has been marked as deprecated and should be removed in Flink 2.0.

Considering SourceFunction / SinkFunction are heavily used in test cases for building a simple data generator or a data validator, it could be a huge amount of work to rewrite all these usages with Source and Sink V2 API. A viable path for 2.0-preview version would be:

• Move SourceFunction, SinkFunction to an internal package, as a test util
• Rewrite all Sink V1 implementations with Sink V2 directly (the usage of Sink V1 is low in the main repo)

As a long term working item, all usages of SourceFunction and SinkFunction will be replaced by Source and Sink API. 

Issue Links

• causes: FLINK-36621 Build failure: StatefulSink not found
• contains: FLINK-33747 Remove Sink V1 API in 2.0
• is related to: FLINK-28046 Annotate SourceFunction as deprecated
• is related to: FLINK-25578 Graduate Sink V1 interfaces to PublicEvolving and deprecate them
• is related to: FLINK-35378 [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction
• links to: GitHub Pull Request #25327
• mentioned in: Page Loading...