FLink 1.13版本升级Flink 1.17 报错 ,怎么处理?RpcLoaderException: could not load RpcSystem
和这个问题差不多 https://www.saoniuhuo.com/question/detail-2743444.html
flink-rpc-core
flink-streaming-java
flink-clients
这些包 以及其他包多有引入 本地运行报错这个RpcLoaderException: could not load RpcSystem
在升级Flink版本时遇到RpcLoaderException: could not load RpcSystem的错误,可能是由于一些原因导致的以下是一些可能的解决方案:
flink-rpc-core
、flink-streaming-java
和flink-clients
等包都已正确引入在升级Flink版本时,要特别注意依赖关系的变化,确保所有相关的依赖项都与新版本的Flink兼容以下是一个示例的Maven依赖项,供你参考:
<dependencies>
<!-- Flink core dependencies -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-core</artifactId>
<version>1.17.0</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.12</artifactId>
<version>1.17.0</version>
</dependency>
<!-- Other dependencies -->
<!-- ... -->
</dependencies>
当您遇到升级 Flink 版本时报 RpcLoaderException: Could not load RpcSystem
错误时,请采取如下措施:
确包
org.apache.flink
flink-rpc-akka
1.17.1
org.apache.flink
flink-rpc-akka-loader
1.17.1
此回答整理自钉群“【②群】Apache Flink China社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。