Mao Jiayi created FLINK-40203:
---------------------------------
Summary: Add explicit option for Flink SQL-compatible YAML
Transform expression semantics
Key: FLINK-40203
URL: https://issues.apache.org/jira/browse/FLINK-40203
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: Mao Jiayi
CDC YAML Transform currently has legacy expression semantics for some row-level
transform predicates. Aligning these predicates directly with Flink SQL may
introduce backward-incompatible silent result changes.
For example, comparison predicates, IN / NOT IN, BETWEEN / NOT BETWEEN, and
two-argument LIKE / NOT LIKE may produce different results after switching from
the current legacy behavior to Flink SQL semantics. In CDC pipelines, such
silent filter result changes can alter which INSERT / UPDATE / DELETE events
reach the sink without causing job failures.
This issue proposes introducing an explicit pipeline option to control
transform expression semantics, so backward-incompatible semantic alignment can
be enabled intentionally. The default behavior should remain
backward-compatible.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
