[jira] [Created] (FLINK-18784) Push Projection through WatermarkAssigner

["Jark Wu (Jira)" <ji...@apache.org>]

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)