復現:

$FLINK_HOME/bin/sql-client.sh embedded -d $FLINK_HOME/conf/flink-hive.yaml

完整報錯如下:

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.main(SqlClient.java:208) Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could not create execution context.at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:878)at org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:226)at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)at org.apache.flink.table.client.SqlClient.main(SqlClient.java:196) Caused by: org.apache.flink.table.catalog.exceptions.CatalogException: Failed to create Hive Metastore clientat org.apache.flink.table.catalog.hive.client.HiveShimV310.getHiveMetastoreClient(HiveShimV310.java:105)at org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.createMetastoreClient(HiveMetastoreClientWrapper.java:245)at org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.<init>(HiveMetastoreClientWrapper.java:76)at org.apache.flink.table.catalog.hive.client.HiveMetastoreClientFactory.create(HiveMetastoreClientFactory.java:35)at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:245)at org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:190)at org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:338)at org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$null$5(ExecutionContext.java:635)at java.util.HashMap.forEach(HashMap.java:1288)at org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:633)at org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:266)at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:632)at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:529)at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:185)at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:138)at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:867)... 3 more Caused by: java.lang.NoSuchMethodException: org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(org.apache.hadoop.conf.Configuration, boolean)at java.lang.Class.getMethod(Class.java:1786)at org.apache.flink.table.catalog.hive.client.HiveShimV310.getHiveMetastoreClient(HiveShimV310.java:101)... 18 more

解決方案:

flink-sql-connector-hive-3.1.2_2.11-1.12.0.jar

放入$FLINK_HOME/lib下面即可

?

Reference:

[1]Hive -Supported Hive Versions

?

?

總結

以上是生活随笔為你收集整理的org.apache.flink.table.catalog.exceptions.CatalogException: Failed to create Hive Metastore client的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。