[FLINK-25420] Port JDBC Source to new Source API (FLIP-27)

• Type: Improvement
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Component/s: Connectors / JDBC
• Assignee: RocMarshal
• Reporter: Martijn Visser
• Created: 22/Dec/21 14:37
• Updated: 06/Nov/23 16:59

Description

The current JDBC connector is using the old SourceFunction interface, which is going to be deprecated. We should port/refactor the JDBC Source to use the new Source API, based on FLIP-27 https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface

Issue Links

• Wiki Page: Wiki Page Loading...

Sub-Tasks

• Support the new source that keeps the same functionality as the original JDBC input format: Resolved
• Support property authentication connection.: Resolved
• Support streaming related semantics for the new JDBC source: Resolved
• Sort out the document page about the new Jdbc source.: Resolved
• Support the implementation of dynamic source tables based on the new source: Reopened
• Support property authentication connection for JDBC catalog & dynamic table: Resolved