Skip to content

[FLINK-39976][pipeline-connector/db2] Add DB2 Pipeline connector#4454

Open
Daishuyuan wants to merge 4 commits into
apache:masterfrom
Daishuyuan:FLINK-39976
Open

[FLINK-39976][pipeline-connector/db2] Add DB2 Pipeline connector#4454
Daishuyuan wants to merge 4 commits into
apache:masterfrom
Daishuyuan:FLINK-39976

Conversation

@Daishuyuan

@Daishuyuan Daishuyuan commented Jun 29, 2026

Copy link
Copy Markdown
Contributor

Purpose of the change

Add DB2 as a Flink CDC pipeline connector so users can define DB2 sources in pipeline jobs.

Brief change log

  • Add the flink-cdc-pipeline-connector-db2 module and register its factory.
  • Implement DB2 pipeline source, data source options, metadata columns, type/schema utilities, record emitter, and event deserializer.
  • Add DB2 source connector updates required by the pipeline connector.
  • Add English and Chinese DB2 pipeline connector documentation and overview entries.
  • Add focused unit and container test classes for DB2 source and pipeline connector behavior.

@github-actions github-actions Bot added docs Improvements or additions to documentation db2-cdc-connector labels Jun 29, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

db2-cdc-connector docs Improvements or additions to documentation

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant