Configured default database db1 doesn‘t exist in catalog myhive.

以你之姓@ 2023-01-03 01:20 199阅读 0赞

去hive检查会发现db1是存在的.

但是启动 flink sql client 的时候会发现提示myhive中找到db1的问题

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: Configured default database db1 doesn’t exist in catalog myhive.
at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:250)
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.(ExecutionContext.java:185)
at org.apache.flink.table.client.gateway.local.ExecutionContext.(ExecutionContext.java:138)
at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:867)
… 3 more

解决方案:

flink-sql-connector-hive.**.jar

hive版本

flink版本

$FLINK_HOME/conf/.yaml

检查这四个东西中的版本或者设置确保兼容.

发表评论

表情:
评论列表 (有 0 条评论,199人围观)

还没有评论,来说两句吧...

相关阅读