JasonLee created FLINK-23171:
--------------------------------
Summary: Can't execute SET table.sql-dialect=hive;
Key: FLINK-23171
URL: https://issues.apache.org/jira/browse/FLINK-23171
Project: Flink
Issue Type: Bug
Components: Connectors / Hive
Affects Versions: 1.13.1
Environment: Flink 1.13.1
hive 2.3.4
Reporter: JasonLee
Fix For: 1.14.0
sql client throw an exception when I switch dialects like this
SET table.sql-dialect=hive;
The exception is as follows:
{code:java}
// code placeholder
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
Unexpected exception. This is a bug. Please consider filing an issue.Exception
in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected
exception. This is a bug. Please consider filing an issue. at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201) at
org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)Caused by:
java.lang.BootstrapMethodError: java.lang.NoSuchMethodError:
org.apache.flink.table.planner.delegation.PlannerContext.createSqlExprToRexConverter(Lorg/apache/calcite/rel/type/RelDataType;)Lorg/apache/flink/table/planner/calcite/SqlExprToRexConverter;
at
org.apache.flink.table.planner.delegation.hive.HiveParserFactory.create(HiveParserFactory.java:39)
at
org.apache.flink.table.planner.delegation.PlannerBase.createNewParser(PlannerBase.scala:144)
at
org.apache.flink.table.planner.delegation.PlannerBase.getParser(PlannerBase.scala:149)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.getParser(TableEnvironmentImpl.java:1466)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.<init>(TableEnvironmentImpl.java:237)
at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.<init>(StreamTableEnvironmentImpl.java:113)
at
org.apache.flink.table.client.gateway.context.ExecutionContext.createStreamTableEnvironment(ExecutionContext.java:156)
at
org.apache.flink.table.client.gateway.context.ExecutionContext.createTableEnvironment(ExecutionContext.java:116)
at
org.apache.flink.table.client.gateway.context.ExecutionContext.<init>(ExecutionContext.java:82)
at
org.apache.flink.table.client.gateway.context.SessionContext.set(SessionContext.java:156)
at
org.apache.flink.table.client.gateway.local.LocalExecutor.setSessionProperty(LocalExecutor.java:164)
at org.apache.flink.table.client.cli.CliClient.callSet(CliClient.java:456) at
org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:403)
at
org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$0(CliClient.java:327)
at java.util.Optional.ifPresent(Optional.java:159) at
org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:327)
at
org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297)
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221)
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151) at
org.apache.flink.table.client.SqlClient.start(SqlClient.java:95) at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) ... 1
moreCaused by: java.lang.NoSuchMethodError:
org.apache.flink.table.planner.delegation.PlannerContext.createSqlExprToRexConverter(Lorg/apache/calcite/rel/type/RelDataType;)Lorg/apache/flink/table/planner/calcite/SqlExprToRexConverter;
at java.lang.invoke.MethodHandleNatives.resolve(Native Method) at
java.lang.invoke.MemberName$Factory.resolve(MemberName.java:975) at
java.lang.invoke.MemberName$Factory.resolveOrFail(MemberName.java:1000) at
java.lang.invoke.MethodHandles$Lookup.resolveOrFail(MethodHandles.java:1389) at
java.lang.invoke.MethodHandles$Lookup.linkMethodHandleConstant(MethodHandles.java:1745)
at
java.lang.invoke.MethodHandleNatives.linkMethodHandleConstant(MethodHandleNatives.java:477)
... 22 more
{code}
I guess there's a packet conflict, But I can execute it in version 1.13.0
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
