Timo Walther created FLINK-7171: ----------------------------------- Summary: Remove identity project for time attributes Key: FLINK-7171 URL: https://issues.apache.org/jira/browse/FLINK-7171 Project: Flink Issue Type: Improvement Components: Table API & SQL Reporter: Timo Walther
If only time attributes are projected away, the translated plan should not contain an additional Calc node. Example: {code} streamUtil.addTable[(Int, String, Long)]( "MyTable", 'a, 'b, 'c, 'proctime.proctime, 'rowtime.rowtime) {code} and {code} streamUtil.addTable[(Int, String, Long)]( "MyTable", 'a, 'b, 'c) {code} Lead to different logical plans even if these attributes are not accessed in {{"SELECT DISTINCT a, b, c FROM MyTable"}}. {code} unaryNode( "DataStreamGroupAggregate", unaryNode( "DataStreamCalc", streamTableNode(0), term("select", "a, b, c") ), term("groupBy", "a, b, c"), term("select", "a, b, c") ) {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)