You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by re...@apache.org on 2024/04/29 12:23:48 UTC

(flink-cdc) branch master updated (23a67dcdb -> f61f0f44b)

This is an automated email from the ASF dual-hosted git repository.

renqs pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


    from 23a67dcdb [FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and processWatermark methods (#3271)
     add f61f0f44b [FLINK-35264][cdc][runtime] Fix multiple transform rules do not take effect (#3280)

No new revisions were added by this update.

Summary of changes:
 .../cdc/pipeline/tests/TransformE2eITCase.java     | 238 +++++++++++++++++++++
 .../src/test/resources/ddl/mysql_inventory.sql     |  24 ++-
 .../src/test/resources/ddl/transform_test.sql      |  29 ++-
 .../transform/TransformSchemaOperator.java         |   2 +-
 4 files changed, 279 insertions(+), 14 deletions(-)
 create mode 100644 flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/TransformE2eITCase.java
 copy flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/resources/ddl/mysql/docker_init.sql => flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/resources/ddl/transform_test.sql (52%)