[FLINK-3486] Use Project to rename all record fields would fail following Project.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: Table SQL / API
• Assignee: Fabian Hueske
• Reporter: Chengxiang Li
• Created: 24/Feb/16 06:43
• Updated: 03/Mar/16 09:19
• Resolved: 03/Mar/16 09:19

Description

 val t = CollectionDataSets.get3TupleDataSet(env).toTable
      .select('_1 as 'a, '_2 as 'b, '_3 as 'c)
      .select('a, 'b)

would throw exception like:

java.lang.IllegalArgumentException: field [a] not found; input fields are: [_1, _2, _3]
	at org.apache.calcite.tools.RelBuilder.field(RelBuilder.java:290)
	at org.apache.calcite.tools.RelBuilder.field(RelBuilder.java:275)
	at org.apache.flink.api.table.plan.RexNodeTranslator$.toRexNode(RexNodeTranslator.scala:80)
	at org.apache.flink.api.table.Table$$anonfun$5.apply(table.scala:98)
	at org.apache.flink.api.table.Table$$anonfun$5.apply(table.scala:98) 

new alias names are lost.

Issue Links

• relates to: FLINK-3508 Add more test cases to verify the rules of logical plan optimization