升级 Apache Flink 需要更新 pom.xml 吗？答案

【问题标题】：Upgrading Apache Flink need to update pom.xml?升级 Apache Flink 需要更新 pom.xml 吗？
【发布时间】：2020-11-12 18:44:56
【问题描述】：

我刚刚将我的 flink 从 1.9.1 升级到 1.11.2（使用 docker）我已经在 1.9.1 版本中运行了许多 flink 作业当我尝试升级到 1.11.1 并重新运行我的作业时，它显示错误。

2020-11-12 06:49:17,731 WARN  org.apache.zookeeper.ClientCnxn                              []

 - SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/tmp/jaas-1135609831848314731.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it.
2020-11-12 06:49:17,739 INFO  org.apache.zookeeper.ClientCnxn                              [] - Opening socket connection to server xxxxxx:2181
2020-11-12 06:49:17,741 ERROR org.apache.curator.ConnectionState                           [] - Authentication failed

这是部署我的 flink 作业后的错误：

原因：java.lang.RuntimeException：API 路径未定义

还有：

java.lang.NoSuchMethodError: org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String;)Lorg/apache/flink/api/common/state/ListState;

我需要为我的 flink 作业更改每个 pom 吗？在不更改我的源代码的情况下有什么解决方法吗？

谢谢

【问题讨论】：

发布错误可能是个好主意，这样您就可以更具体。
在 1.10 和 1.11 中有一些更改，在某些情况下需要进行细微调整。您可以阅读发行说明：ci.apache.org/projects/flink/flink-docs-release-1.11/… 和 ci.apache.org/projects/flink/flink-docs-release-1.11/…，或者告诉我们出了什么问题。
这是我的 pom：org.apache.flinkflink-streaming-java_2.11provided1.9.1org.apache.flinkflink-connector-kafka-0.11_2.111.9.1 我假设它会尝试查找 1.9 版本的 flink lib，而我的新 flink 映像仅包含 1.11 lib jar
请查看以下错误详情：ERROR org.apache.curator.ConnectionState [] - Authentication failed 06:58:18.839 [flink-akka.actor.default-dispatcher-3] ERROR org.apache。 flink.runtime.taskexecutor.TaskExecutor - 由于错误 java.util.concurrent.CompletionException: org.apache.flink.runtime.rpc.exceptions.FencingTokenException: Fencing token not set: Ignoring message And also : Caused by : java.lang.RuntimeException: API 路径未定义

标签： apache-flink

【解决方案1】：

是的，每当您更新用于运行它们的 Flink 版本时，您都必须重新构建您的 Flink 作业。您使用的库应该与作业管理器和任务管理器使用的版本完全相同。

如果您尝试自动化 CI/CD 管道的部署，您可以使用环境变量将版本号注入 pom.xml 中——但是这样做可能会在出现问题时难以调试。

【讨论】：

太糟糕了，bcs flink 版本一直在升级。无论如何，感谢您的回复戴夫