[FLINK-11919] Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "FROM user" at line 1, column 17.

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.7.2
• Fix Version/s: 1.7.2
• Component/s: Table SQL / API

Environment

os: mac 0.14.3 

java: 1.8.0_191

scala: 2.11.12

code: https://github.com/opensourceteams/flink-maven-scala/blob/master/src/main/scala/com/opensourceteams/module/bigdata/flink/example/sql/user/Run.scala

 

• Release Note: some string combinations are already reserved as keywords for future use. If you want to use one of the following strings as a field name, make sure to surround them with backticks (e.g. `value`, `count`).
• Assignee: Unassigned
• Reporter: thinktothings
• Created: 14/Mar/19 09:41
• Updated: 15/Mar/19 01:25
• Resolved: 15/Mar/19 01:25

Description

Register table name, can not use user, use other names, such as user1 can be normal

 

 

===========================================================

package com.opensourceteams.module.bigdata.flink.example.tableapi.test

import org.apache.flink.api.scala.ExecutionEnvironment
import org.apache.flink.table.api.scala._
import org.apache.flink.api.scala._
import org.apache.flink.table.api.TableEnvironment

object Run {

def main(args: Array[String]): Unit =

{ //得到批环境 val env = ExecutionEnvironment.getExecutionEnvironment val dataSet = env.fromElements(("小明",15,"男"),("小李",25,"女")) //得到Table环境 val tableEnv = TableEnvironment.getTableEnvironment(env) //注册table tableEnv.registerDataSet("user",dataSet,'name,'age,'sex) tableEnv.sqlQuery(s"select name,age FROM user") .first(100).print() }

}

 

===========================================================

 

Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "FROM user" at line 1, column 17.
Was expecting one of:
<EOF>
"ORDER" ...
"LIMIT" ...
"OFFSET" ...
"FETCH" ...
"FROM" <IDENTIFIER> ...
"FROM" <QUOTED_IDENTIFIER> ...
"FROM" <BACK_QUOTED_IDENTIFIER> ...
"FROM" <BRACKET_QUOTED_IDENTIFIER> ...
"FROM" <UNICODE_QUOTED_IDENTIFIER> ...
"FROM" "LATERAL" ...
"FROM" "(" ...
"FROM" "UNNEST" ...
"FROM" "TABLE" ...
"," ...
"AS" ...
<IDENTIFIER> ...
<QUOTED_IDENTIFIER> ...
<BACK_QUOTED_IDENTIFIER> ...
<BRACKET_QUOTED_IDENTIFIER> ...
<UNICODE_QUOTED_IDENTIFIER> ...
"." ...
"NOT" ...
"IN" ...
"<" ...
"<=" ...
">" ...
">=" ...
"=" ...
"<>" ...
"!=" ...
"BETWEEN" ...
"LIKE" ...
"SIMILAR" ...
"+" ...
"-" ...
"*" ...
"/" ...
"%" ...
"||" ...
"AND" ...
"OR" ...
"IS" ...
"MEMBER" ...
"SUBMULTISET" ...
"CONTAINS" ...
"OVERLAPS" ...
"EQUALS" ...
"PRECEDES" ...
"SUCCEEDS" ...
"MULTISET" ...
"[" ...
"UNION" ...
"INTERSECT" ...
"EXCEPT" ...
"MINUS" ...
"(" ...

at org.apache.flink.table.calcite.FlinkPlannerImpl.parse(FlinkPlannerImpl.scala:94)
at org.apache.flink.table.api.TableEnvironment.sqlQuery(TableEnvironment.scala:743)
at com.opensourceteams.module.bigdata.flink.example.tableapi.test.Run$.main(Run.scala:28)
at com.opensourceteams.module.bigdata.flink.example.tableapi.test.Run.main(Run.scala)

 

 

=======================================================