You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/13 09:22:00 UTC

[jira] [Closed] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

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

Kurt Young closed FLINK-15167.
------------------------------
    Resolution: Fixed

master: cd4c3ddf

1.10.0: 5a43907e

 

> SQL CLI library option doesn't work for Hive connector
> ------------------------------------------------------
>
>                 Key: FLINK-15167
>                 URL: https://issues.apache.org/jira/browse/FLINK-15167
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Hive, Table SQL / Client
>            Reporter: Rui Li
>            Assignee: Rui Li
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.10.0
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> Launch a standalone cluster. Put all Hive connector dependency jars in a folder and start sql cli like: {{sql-client.sh embedded -l <folder>}}. Hit the following exception:
> {noformat}
> 	at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:186)
> 	at org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:102)
> 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:233)
> 	at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
> 	at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:519)
> 	at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:463)
> 	at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:156)
> 	at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:115)
> 	at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:724)
> 	... 3 more
> Caused by: java.lang.reflect.InvocationTargetException
> 	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.HiveShimV230.getHiveMetastoreClient(HiveShimV230.java:55)
> 	... 15 more
> Caused by: MetaException(message:org.apache.hadoop.hive.metastore.HiveMetaStoreClient class not found)
> 	at org.apache.hadoop.hive.metastore.MetaStoreUtils.getClass(MetaStoreUtils.java:1676)
> 	at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:131)
> 	at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:89)
> 	... 20 more
> {noformat}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)