hi： 1.你可以看下你配置hive catalog时的hive版本和你当前使用的hive版本是否一致 2.你也可以尝试在配置hive catalog的时候，不设置hive版本
-- Best， wldd 在 2020-08-05 15:38:26，"air23" <wangfei23_...@163.com> 写道： >你好 > 15:33:59,781 INFO org.apache.flink.table.catalog.hive.HiveCatalog > - Created HiveCatalog 'myhive1' >Exception in thread "main" >org.apache.flink.table.catalog.exceptions.CatalogException: Failed to create >Hive Metastore client >at >org.apache.flink.table.catalog.hive.client.HiveShimV120.getHiveMetastoreClient(HiveShimV120.java:58) >at >org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.createMetastoreClient(HiveMetastoreClientWrapper.java:240) >at >org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.<init>(HiveMetastoreClientWrapper.java:71) >at >org.apache.flink.table.catalog.hive.client.HiveMetastoreClientFactory.create(HiveMetastoreClientFactory.java:35) >at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:223) >at >org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:191) >at >org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:337) >at com.zt.kafka.KafkaTest4.main(KafkaTest4.java:73) >Caused by: java.lang.NoSuchMethodException: >org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(org.apache.hadoop.hive.conf.HiveConf) >at java.lang.Class.getMethod(Class.java:1786) >at >org.apache.flink.table.catalog.hive.client.HiveShimV120.getHiveMetastoreClient(HiveShimV120.java:54) >... 7 mor > > > > >请问这个是什么问题 Metastore 也已经启动了。 >谢谢
