Commit b0a7d92

authored

[FLINK-36866][transform] Fix unable to narrow casting on numeric values

This closes #3786.

1 parent 39b560e commit b0a7d92Copy full SHA for b0a7d92

3 files changed

+425

-23

lines changed

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink
- FlinkPipelineTransformITCase.java
flink-cdc-runtime/src
- main/java/org/apache/flink/cdc/runtime/functions
  - SystemFunctionUtils.java
- test/java/org/apache/flink/cdc/runtime/operators/transform
  - PostTransformOperatorTest.java

+425

-23

lines changed

Comments

(0)