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

Question

我刚刚将我的flink从1.9.1升级到1.11.2 (使用docker) --当我尝试升级到1.11.1并重新运行我的作业时，已经有许多flink作业在1.9.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路径引起

还包括：

org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String;)Lorg/apache/flink/api/common/state/ListState；：

java.lang.NoSuchMethodError

我需要为我的flink工作改变每一份工作吗？在不改变我的源代码的情况下，有什么工作要做吗？

谢谢

Answer 1

是的，无论何时更新用于运行Flink的Flink版本，您都必须重新构建Flink作业。您使用的库应该来自“职务管理器”和“任务管理器”使用的相同版本。

如果您试图自动化CI/CD管道的部署，可以使用环境变量将版本号插入到pom.xml中--但是这样做会使出错时很难调试。