Daishuyuan created FLINK-39976:
----------------------------------
Summary: Flink cdc pipeline support db2 source pipeline connector
Key: FLINK-39976
URL: https://issues.apache.org/jira/browse/FLINK-39976
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: Daishuyuan
* Motivation
Flink CDC already provides DB2 CDC source / incremental source support, but the
pipeline connector side is still missing. This makes DB2 inconsistent with the
other databases already supported by the pipeline framework, and prevents users
from using DB2 CDC in the unified pipeline mode.
Existing related issue FLINK-34842 covers DB2 incremental source support, but
it does not track the missing DB2 pipeline connector. There was also an old
GitHub PR apache/flink-cdc#3450 for DB2 pipeline source support, but it was
closed as stale and was not merged.
* What is proposed
This change adds a new DB2 pipeline connector module and integrates it into the
pipeline connectors build, following the same style as the SQL Server pipeline
connector task FLINK-39252.
The implementation should reuse the existing DB2 source connector capabilities
where possible and provide the required pipeline connector factory, options,
metadata handling, documentation, and tests so DB2 can be used in Flink CDC
pipeline YAML mode.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)