apache / flink-cdc

[FLINK-38806] Fix post-transform converters ineffective without projection or filter rules (#4191)

yuxiqian

yuxiqian committed on Dec 16, 2025, 06:58 AM

Showing 3 changed files +39 additions -25 deletions

M flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java -10

M flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/TransformTranslator.java +9 -11

M flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java +30 -4

Browse files at this commit →