Re: flink tableapi inner join exception

2019-03-15 Thread Xingcan Cui
Hi, As the message said, some columns share the same names. You could first rename the columns of one table with the `as` operation [1]. Best, Xingcan [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/tableApi.html#scan-projection-and-filter > On Mar 15, 2019, at 9:03 AM,

flink tableapi inner join exception

2019-03-15 Thread 刘 文
Exception in thread "main" org.apache.flink.table.api.ValidationException: join relations with ambiguous names: id, name, value at org.apache.flink.table.plan.logical.LogicalNode.failValidation(LogicalNode.scala:156) at org.apache.flink.table.plan.logical.Join.validate(operators.