[
https://issues.apache.org/jira/browse/FLINK-40508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18114619#comment-18114619
]
suntectec commented on FLINK-40508:
-----------------------------------
Hi all,
I have opened a pull request for this issue:
https://github.com/apache/flink-cdc/pull/4533
The PR adds a new \{{flink-cdc-pipeline-connector-db2}} module so that DB2 can
be used as a Pipeline (YAML API) source. It reuses the existing
\{{flink-connector-db2-cdc}} through the incremental snapshot framework, so no
change is made to the source connector itself. English and Chinese docs,
\{{Db2TypeUtilsTest}} unit tests and testcontainers ITCases
(\{{Db2DataSourceFactoryITCase}}, \{{Db2PipelineITCase}}) are included, and the
module is registered in \{{.github/workflows/modules.py}} so CI covers it on
both Flink 1.20.3 and 2.2.0.
The DB2 ITCases have been executed successfully on both Flink profiles on CI
(see https://github.com/suntectec/flink-cdc/pull/1). The upstream workflow run
is currently waiting for a committer to approve it.
PTAL, thanks!
> Support DB2 pipeline connector
> ------------------------------
>
> Key: FLINK-40508
> URL: https://issues.apache.org/jira/browse/FLINK-40508
> Project: Flink
> Issue Type: New Feature
> Components: Flink CDC
> Reporter: suntectec
> Priority: Major
> Labels: pull-request-available
>
> Introduce the DB2 source connector for the Flink CDC YAML pipeline API,
> supporting snapshot + incremental reading, schema change events, and readable
> metadata.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
