Skip to content

[FLINK-40508][pipeline-connector/db2] Support Db2 pipeline connector - #4524

Open
suntectec wants to merge 4 commits into
apache:masterfrom
suntectec:feat/db2-pipeline-feature
Open

[FLINK-40508][pipeline-connector/db2] Support Db2 pipeline connector#4524
suntectec wants to merge 4 commits into
apache:masterfrom
suntectec:feat/db2-pipeline-feature

Conversation

@suntectec

@suntectec suntectec commented Sep 6, 2026

Copy link
Copy Markdown
Contributor

What is the purpose of this pull request?

JIRA: FLINK-40508
Add Db2 pipeline connector so users can define Db2 sources in CDC YAML pipelines.

Brief change log

  • New flink-cdc-pipeline-connector-db2 module with factory and source implementation
  • Db2 data source options, metadata columns, schema utilities, record emitter, event deserializer
  • Updates to flink-connector-db2-cdc for pipeline compatibility
  • Integration tests (Db2PipelineITCase) and documentation (EN/CN)

Verifying this change

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change added tests and can be verified as follows:

  • Db2PipelineITCase covers snapshot and CDC with metadata, using Testcontainers
  • Passed locally; CI verified on fork

Documentation

  • Yes, new feature; documented in connector overview (EN/CN)

Was generative AI tooling used to co-author this PR?
  • Yes (please specify the tool below)
    Generated-by: Qoder Qwen

… randomized CI time zones

The CI passes a randomized -Duser.timezone to Maven, and Surefire forwards
this user property into the forked test JVM, overriding the UTC pin in the
module's surefire argLine. Since Db2 resolves LSN timestamps with the JVM
default time zone, the op_ts value shifts by the zone offset and the
wall-clock comparison fails. Assert op_ts is a valid change timestamp (> 0)
instead, following the Postgres connector test pattern, and drop the
ineffective surefire argLine override.
@github-actions github-actions Bot added docs Improvements or additions to documentation build labels Sep 6, 2026
@suntectec suntectec closed this Sep 6, 2026
@suntectec suntectec changed the title [FLINK-40508] DB2 Pipeline Connector [FLINK-40508][pipeline-connector/db2] Support Db2 pipeline connector Sep 6, 2026
@suntectec suntectec reopened this Sep 6, 2026
@suntectec
suntectec marked this pull request as draft September 6, 2026 11:21
@suntectec
suntectec marked this pull request as ready for review September 6, 2026 11:40
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

build docs Improvements or additions to documentation

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant