org.apache.flink.table.catalog.exceptions.CatalogException: Failed to create Hive Metastore client
复现:
$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相关推荐
- Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSinkFactory‘
報錯如下: Exception in thread "main" org.apache.flink.table.api.TableException: findAndCreateT ...
- java.lang.String cannot be cast to org.apache.flink.table.data.StringData
完整报错: 16:54:56,851 INFO org.apache.hadoop.conf.Configuration.deprecation - io.bytes.per.checksum is ...
- java.lang.NoSuchMethodError: org.apache.flink.table.api.TableColumn.isGenerated()Z
完整报错如下: select * from dim_behavior; [ERROR] Could not execute SQL statement. Reason: java.lang.NoSuc ...
- Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory‘
启动FLINK SQL Client的时候 $FLINK_HOME/bin/sql-client.sh embedded -d $FLINK_HOME/conf/sql.my.yaml -l /hom ...
- Cannot resolve method ‘call(java.lang.String, org.apache.flink.table.api.ApiExpression)‘
intellij提示: Cannot resolve method 'call(java.lang.String, org.apache.flink.table.api.ApiExpression)' ...
- org.apache.flink.table.api.bridge.java.internal.BatchTableEnvironmentImpl找不到的问题
Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.api.bridge.java.internal.BatchTa ...
- org.apache.flink.table.api.TableException: A raw type backed by type information has no serializable
DataStream<Order> result = tableEnv.toAppendStream(table, Order.class); 出现这个问题是因为Order类是嵌套内部类, ...
- 基于 Apache Flink Table Store 的全增量一体实时入湖
摘要:本文简要回顾了数据入湖(仓)的发展阶段,针对在数据库数据入湖中面临的问题,提出了使用 Flink Table Store 作为全增量一体入湖的解决方案,并辅以开源 Demo 的测试结果作为展示. ...
- 报错：Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory
重要错误提示: Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suit ...
最新文章
- merge r语言daframe_R语言读取多个excel文件后合并：rbind/merge/cmd合并
- oracle控制文件都一样么,Oracle控制文件详解
- MSD3458开发资料
- 6.4高级查询：分组查询 链接查询 子查询 联合查询
- 拦截导弹 (加了神奇的位运算)
- Cocos 技术派：实时竞技小游戏技术实现分享
- 无线对讲调度服务器,无线对讲系统解决方案
- php zend 多个站错误,php – 如何显示Zend框架抛出的异常错误
- 启动wcc显示本地服务器失败,cwrsync server 服务启动失败的解决方法小结
- 七个你一定会犯的云安全错误
- WordPress优化教程让WordPress打开速度更快
- MD5生成与校验（Linux/UNIX/Windows）
- X86平台操作系统概览 zz
- 学生个人网页设计作品 HTML+CSS+JavaScript仿小米商城(8页) 学生个人网页模板 简单个人主页成品 个人网页制作 HTML学生个人网站作业设计代做
- 债转股问题研究（lunwen+开题报告+外文翻译）
- [Kaggle Classify-Leaves] 树叶分类 score0.950
- LOGO（小海龟）编程之父留给我们的思想遗产
- 【分享】这些年，我使用的一些工具[非开发类]
- 《JAVA程序设计》期末考试复习题
- 数字人民币试点新场景多点开花，多品种“硬件钱包”触达平常百姓家