请教一下,我在用flink-sql-gateway的1.11.1版本的SET语法设置hive dialect时(SET table.sql-dialect=hive),flink-sql-gateway出现了报错,同样的语法在sql-client是支持的,那如果我想在session级切换hive dialect我应该怎么做呢? 多谢 我的环境如下: flink-sql-gateway:1.11.1 flink:1.11.1 hive:3.1.2 hadoop:3.0.0 日志如下: 2020-08-31 20:39:56,051 INFO com.ververica.flink.table.gateway.rest.session.Session [] - Session: dc5b8e66111bd59a4c7abe0acc625275, runstatement: set table.sql-dialect=hive 2020-08-31 20:39:56,051 ERROR com.ververica.flink.table.gateway.rest.session.Session [] - Session: dc5b8e66111bd59a4c7abe0acc625275, Failed to parse statement: set table.sql-dialect=hive 2020-08-31 20:39:56,052 ERROR com.ververica.flink.table.gateway.rest.handler.StatementExecuteHandler [] - Exception occurred in REST handler. org.apache.flink.runtime.rest.handler.RestHandlerException: Failed to parse statement. at com.ververica.flink.table.gateway.rest.handler.StatementExecuteHandler.handleRequest(StatementExecuteHandler.java:91) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?] ... Caused by: com.ververica.flink.table.gateway.utils.SqlGatewayException: Failed to parse statement. at com.ververica.flink.table.gateway.rest.session.Session.runStatement(Session.java:102) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?] at com.ververica.flink.table.gateway.rest.handler.StatementExecuteHandler.handleRequest(StatementExecuteHandler.java:81) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?] ... 43 more Caused by: org.apache.calcite.sql.parser.SqlParseException: Encountered "table" at line 1, column 5. Was expecting one of: <BRACKET_QUOTED_IDENTIFIER> ... <QUOTED_IDENTIFIER> ... <BACK_QUOTED_IDENTIFIER> ... <IDENTIFIER> ... <UNICODE_QUOTED_IDENTIFIER> ... ... Caused by: org.apache.flink.sql.parser.impl.ParseException: Encountered "table" at line 1, column 5. Was expecting one of: <BRACKET_QUOTED_IDENTIFIER> ... <QUOTED_IDENTIFIER> ... <BACK_QUOTED_IDENTIFIER> ... <IDENTIFIER> ... <UNICODE_QUOTED_IDENTIFIER> ...
at org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.generateParseException(FlinkSqlParserImpl.java:36086) ~[flink-table_2.11-1.11.1.jar:1.11.1] ... -- Sent from: http://apache-flink.147419.n8.nabble.com/