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)

Reply via email to