Jark Wu created FLINK-18784: ------------------------------- Summary: Push Projection through WatermarkAssigner Key: FLINK-18784 URL: https://issues.apache.org/jira/browse/FLINK-18784 Project: Flink Issue Type: Sub-task Components: Table SQL / Planner Reporter: Jark Wu Fix For: 1.12.0
Currently, a projection on a watermark table can't push the projection into the source, this is because the projection can't be pushed down throgh watermark node. {code:java} Calc(select=[a, b, rowtime]) : +- WatermarkAssigner(rowtime=[rowtime], watermark=[rowtime]) : +- Calc(select=[a, b, c, PROCTIME() AS proctime, rowtime]) : +- TableSourceScan(table=[[default_catalog, default_database, wmTable1]], fields=[a, b, c, rowtime]) {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)