Sergey Nuyanzin created FLINK-38086:
---------------------------------------
Summary: Make ChangelogNormalize reusable if possible
Key: FLINK-38086
URL: https://issues.apache.org/jira/browse/FLINK-38086
Project: Flink
Issue Type: Technical Debt
Components: Table SQL / Planner
Reporter: Sergey Nuyanzin
Assignee: Sergey Nuyanzin
Sometimes there might be several ChangelogNormalize nodes like
{code:sql}
SELECT * FROM T WHERE f1 > 0
UNION
SELECT * FROM T WHERE f1 < 10
{code}
Currently filters are pushdown and changelog normalize can not be reused
--
This message was sent by Atlassian Jira
(v8.20.10#820010)