Daishuyuan opened a new pull request, #4454: URL: https://github.com/apache/flink-cdc/pull/4454
## 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. ## Verifying this change - `mvn -pl flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc -Dtest='Db2ConnectionQueryTest,Db2StreamingChangeEventSourceTest,Db2ValueConvertersTest' -DfailIfNoTests=false test` - `mvn -pl flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc,flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-db2 -Dtest='Db2DataSourceFactoryTest,Db2EventDeserializerTest,Db2PipelineRecordEmitterTest,Db2ReadableMetadataTest,Db2SchemaUtilsTest,Db2TypeUtilsTest' -DfailIfNoTests=false test` - Spotless and Checkstyle for both DB2 modules. - `git diff --cached --check` Full DB2 Testcontainers tests were not run locally. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
