Jark Wu created FLINK-30129: ------------------------------- Summary: Push projection through ChangelogNormalize Key: FLINK-30129 URL: https://issues.apache.org/jira/browse/FLINK-30129 Project: Flink Issue Type: New Feature Components: Table SQL / Planner Reporter: Jark Wu
Currently, the ChangelogNormalize node is generated during the physical optimization phase. That means the projection is not pushed through ChangelogNormalize if the {{TableSource}} doesn't support {{SupportsProjectionPushDown}}. We can implement such optimization to reduce the state size (fewer columns in state value) and better throughput (only changes on the selected columns will be emitted). -- This message was sent by Atlassian Jira (v8.20.10#820010)