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)

Reply via email to