去hive檢查會發(fā)現(xiàn)db1是存在的.

?但是啟動 flink sql client 的時候會發(fā)現(xiàn)提示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.<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
?

解決方案:

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

hive版本

flink版本

$FLINK_HOME/conf/.yaml

檢查這四個東西中的版本或者設(shè)置確保兼容.

總結(jié)

以上是生活随笔為你收集整理的Configured default database db1 doesn‘t exist in catalog myhive.的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。