yux created FLINK-36093: --------------------------- Summary: PreTransform operator wrongly filters out columns when multiple transform rules were defined Key: FLINK-36093 URL: https://issues.apache.org/jira/browse/FLINK-36093 Project: Flink Issue Type: Improvement Components: Flink CDC Reporter: yux
Currently, such transform rule could not work: ```yaml transform: - projection: 'A' as result filter: tag >= 0 - projection: score as result filter: tag < 0 ``` Here, `score` column will be filtered out in PreTransform stage, since it wasn't referenced in the first transform rule. As a result, the following transform rule will fail since `score` does not exist in PostTransform operator. -- This message was sent by Atlassian Jira (v8.20.10#820010)