[
https://issues.apache.org/jira/browse/FLINK-39976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daishuyuan updated FLINK-39976:
-------------------------------
Description:
* 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
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.
was:
* 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.
> 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
> Priority: Major
>
> * 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
> 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)
