flink-sql-gateway还会更新吗

[丁浩浩]

flink1.11用不了flink-sql-gateway,不知道还会不会更新



[hidden email]

[shougou]

也有同样的问题，同时也问一下，sql client 计划在哪个版本支持gateway模式？多谢



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[godfrey he]

我们会在这周让flink-sql-gateway支持1.11，请关注
另外，sql-client支持gateway模式，据我所知目前还没计划。

shougou <[hidden email]> 于2020年8月24日周一 上午9:48写道：

> 也有同样的问题，同时也问一下，sql client 计划在哪个版本支持gateway模式？多谢
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

[godfrey he]

已更新至flink1.11.1

godfrey he <[hidden email]> 于2020年8月24日周一 下午9:45写道：

> 我们会在这周让flink-sql-gateway支持1.11，请关注
> 另外，sql-client支持gateway模式，据我所知目前还没计划。
>
> shougou <[hidden email]> 于2020年8月24日周一 上午9:48写道：
>
>> 也有同样的问题，同时也问一下，sql client 计划在哪个版本支持gateway模式？多谢
>>
>>
>>
>> --
>> Sent from: http://apache-flink.147419.n8.nabble.com/
>
>

[shougou]

感谢各位的辛苦付出，今天就准备试一下。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[zongsforce]

请教一下，我在用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/