[jira] [Closed] (FLINK-29686) Flink-SQL使用Hive方言出现bug

["Dawid Wysakowicz (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-29686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dawid Wysakowicz closed FLINK-29686.
------------------------------------
    Resolution: Invalid

Please use English in the open-source JIRA. Feel free to translate the ticket to English and reopen the ticket.

> Flink-SQL使用Hive方言出现bug
> ----------------------
>
>                 Key: FLINK-29686
>                 URL: https://issues.apache.org/jira/browse/FLINK-29686
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Hive, Table SQL / Client
>    Affects Versions: 1.14.4
>         Environment: Flink-ver : 1.14.4-on-cdh6.3.2
> Flink-sql-cli : 1.14.4
>            Reporter: Vincent Long
>            Priority: Blocker
>
> 我在使用sql-cli提交任务到session集群的过程中, 我通过Flink-sql-connectors-hive 使用hive方言执行sql代码时发生了如下报错: 
> Exception in thread "main" org.apache.flink.table.client.SqlClientException: {color:#FF0000}Unexpected exception. This is a bug. Please consider filing an issue.{color}
>     at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201)
>     at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
> {color:#FF0000}Caused by: java.lang.ExceptionInInitializerError{color}
>     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
>     at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
>     at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
>     at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
>     at org.apache.hive.common.util.ReflectionUtil.newInstance(ReflectionUtil.java:83)
>     at org.apache.hadoop.hive.ql.exec.Registry.registerUDAF(Registry.java:238)
>     at org.apache.hadoop.hive.ql.exec.Registry.registerUDAF(Registry.java:231)
>     at org.apache.hadoop.hive.ql.exec.FunctionRegistry.<clinit>(FunctionRegistry.java:430)
>     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>     at java.lang.reflect.Method.invoke(Method.java:498)
>     at org.apache.flink.table.catalog.hive.client.HiveShimV120.registerTemporaryFunction(HiveShimV120.java:262)
>     at org.apache.flink.table.planner.delegation.hive.HiveParser.parse(HiveParser.java:207)
>     at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$parseStatement$1(LocalExecutor.java:172)
>     at org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
>     at org.apache.flink.table.client.gateway.local.LocalExecutor.parseStatement(LocalExecutor.java:172)
>     at org.apache.flink.table.client.cli.CliClient.parseCommand(CliClient.java:396)
>     at org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:324)
>     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 more
> {color:#FF0000}Caused by: java.lang.RuntimeException: java.lang.IllegalArgumentException: Unrecognized Hadoop major version number: 3.0.0-cdh6.3.2{color}
>     at org.apache.hadoop.hive.shims.ShimLoader.getHadoopShims(ShimLoader.java:102)
>     at org.apache.hadoop.hive.ql.udf.UDAFPercentile.<clinit>(UDAFPercentile.java:51)
>     ... 25 more
> Caused by: java.lang.IllegalArgumentException: Unrecognized Hadoop major version number: 3.0.0-cdh6.3.2
>     at org.apache.hadoop.hive.shims.ShimLoader.getMajorVersion(ShimLoader.java:177)
>     at org.apache.hadoop.hive.shims.ShimLoader.loadShims(ShimLoader.java:144)
>     at org.apache.hadoop.hive.shims.ShimLoader.getHadoopShims(ShimLoader.java:99)
>     ... 26 more
> Shutting down the session...
> done.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)