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

[jira] [Updated] (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 ]

Rui Li updated FLINK-15167:
---------------------------
    Description: 
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}

  was:
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}


> 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
>            Priority: Major
>
> 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)