apache-flink - 这是 Flink-1.13.1 和 HiveCatalog 中的错误

Question

弗林克：1.13.1

蜂巢：2.1.1—cdh6.2.1

flink/lib目录下的jar包如下图。 在此处输入图片描述 执行 sql-client.sh 时出现以下错误，需要我向 Apache Flink 社区提交评论。

 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.catalog.exceptions.CatalogException: A database with name [hive] does not exist in the catalog: [myhive].
        at org.apache.flink.table.catalog.CatalogManager.setCurrentDatabase(CatalogManager.java:295)
        at org.apache.flink.table.api.internal.TableEnvironmentImpl.useDatabase(TableEnvironmentImpl.java:1450)
        at java.util.Optional.ifPresent(Optional.java:159)
        at org.apache.flink.table.client.gateway.context.LegacyTableEnvironmentInitializer.initializeCatalogs(LegacyTableEnvironmentInitializer.java:202)
        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

标签： apache-flinkflink-sql

Answer 1

您将针对不同（且不兼容）版本的 scala 编译的库混合在一起。那是行不通的。选择 2.11 或 2.12 并始终如一地使用它。