You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "yux (Jira)" <ji...@apache.org> on 2024/08/19 09:09:00 UTC
[jira] [Created] (FLINK-36093) PreTransform operator wrongly filters out columns when multiple transform rules were defined
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)