[
https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371195#comment-17371195
]
JohnSmith commented on FLINK-23171:
-----------------------------------
antlr-runtime-3.5.2.jar
commons-configuration-1.6.jar
commons-logging.jar
flink-connector-hive_2.11-1.13.1.jar
flink-connector-kafka_2.11-1.13.0.jar
flink-csv-1.13.1.jar
flink-dist_2.11-1.13.1.jar
flink-json-1.13.1.jar
flink-shaded-zookeeper-3.4.14.jar
flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar
flink-table_2.11-1.13.1.jar
flink-table-blink_2.11-1.13.1.jar
hadoop-auth-2.6.0-cdh5.12.2.jar
hadoop-common-2.0.0-cdh4.7.1.jar
hadoop-hdfs-2.0.0-cdh4.7.1.jar
hadoop-mapreduce-client-core-2.6.0-cdh5.12.2.jar
hive-exec-1.1.0.jar
hive-metastore-1.1.0.jar
kafka_2.11-0.11.0.1.jar
kafka-clients-2.4.1.jar
libfb303-0.9.2.jar
log4j-1.2-api-2.12.1.jar
log4j-api-2.12.1.jar
log4j-core-2.12.1.jar
log4j-slf4j-impl-2.12.1.jar
This is my lib list. And I can import the class in scala shell
[~luoyuxia] thanks for any update
> 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
> Priority: Major
> 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)
