你好，想问一下你的 hive 包确定是1.13对应的版本吗？ Best, Shengkai
drewfranklin <[email protected]> 于2021年11月22日周一 上午9:45写道： > Hello > 我按照官方文档使用 sql client 去连接hive catalog 时出错。 > 我的hive version 2.3.6 > Flink version 1.13.1 > > 感觉官方介绍的bundled 方式添加jar 包，在flink/lib 下添加如下截图的包。然后重启集群，启动了sql-client > ，连接报错如下，看报错感觉缺包，不知道缺什么包。第二种方式也尝试了下，一样的报错。似乎无法创建catalog 连接。 直接在sql 客户端通过DDL > 的方式注册也是报相同的错误 > Yaml 文件： > > > Reading session environment from: > file:/Users/feng/flink-1.13.1/bin/../catlog_yaml/hiveCatalog.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.startClient(SqlClient.java:201) > at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) > Caused by: org.apache.flink.table.api.ValidationException: Unable to > create catalog 'myhive'. > > Catalog options are: > 'hive-conf-dir'='/Users/feng/hive-2.3.6/conf' > 'type'='hive' > at > org.apache.flink.table.factories.FactoryUtil.createCatalog(FactoryUtil.java:270) > at > org.apache.flink.table.client.gateway.context.LegacyTableEnvironmentInitializer.createCatalog(LegacyTableEnvironmentInitializer.java:217) > at > org.apache.flink.table.client.gateway.context.LegacyTableEnvironmentInitializer.lambda$initializeCatalogs$1(LegacyTableEnvironmentInitializer.java:120) > at java.base/java.util.HashMap.forEach(HashMap.java:1336) > at > org.apache.flink.table.client.gateway.context.LegacyTableEnvironmentInitializer.initializeCatalogs(LegacyTableEnvironmentInitializer.java:117) > at > org.apache.flink.table.client.gateway.context.LegacyTableEnvironmentInitializer.initializeSessionState(LegacyTableEnvironmentInitializer.java:105) > at > org.apache.flink.table.client.gateway.context.SessionContext.create(SessionContext.java:233) > at > org.apache.flink.table.client.gateway.local.LocalContextUtils.buildSessionContext(LocalContextUtils.java:100) > at > org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:91) > at org.apache.flink.table.client.SqlClient.start(SqlClient.java:88) > at > org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) > ... 1 more > Caused by: org.apache.flink.table.api.TableException: Could not load > service provider for factories. > at > org.apache.flink.table.factories.FactoryUtil.discoverFactories(FactoryUtil.java:507) > at > org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:298) > at > org.apache.flink.table.factories.FactoryUtil.getCatalogFactory(FactoryUtil.java:455) > at > org.apache.flink.table.factories.FactoryUtil.createCatalog(FactoryUtil.java:251) > ... 11 more > Caused by: java.util.ServiceConfigurationError: > org.apache.flink.table.factories.Factory: > org.apache.flink.table.module.hive.HiveModuleFactory not a subtype > at java.base/java.util.ServiceLoader.fail(ServiceLoader.java:589) > at > java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNextService(ServiceLoader.java:1237) > at > java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNext(ServiceLoader.java:1265) > at > java.base/java.util.ServiceLoader$2.hasNext(ServiceLoader.java:1300) > at > java.base/java.util.ServiceLoader$3.hasNext(ServiceLoader.java:1385) > at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132) > at > org.apache.flink.table.factories.FactoryUtil.discoverFactories(FactoryUtil.java:503) > ... 14 more > > drewfranklin > [email protected] > > <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=drewfranklin&uid=drewfranklin%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fqiyelogo%2FdefaultAvatar.png&items=%5B%22drewfranklin%40163.com%22%5D> > 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制 >
