tongchenkeji
发表于：0次点击

FLink 1.13版本升级Flink 1.17 报错 ，怎么处理？[阿里云实时计算 Flink版]

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版# 实时计算 Flink版3179# 流计算2236
=====这是一个广告位，招租中，联系qq 78315851====
实时计算Flink版
Flink有自定义sink saphana的样例吗？批次写入的样例[阿里云实时计算 Flink版]
实时计算Flink版
flink sql金额字段如何不失真 ？[阿里云实时计算 Flink版]
2 条回复 A 作者 M 管理员

  1. 在升级Flink版本时遇到RpcLoaderException: could not load RpcSystem的错误，可能是由于一些原因导致的以下是一些可能的解决方案：

    1. 检查依赖关系：确保所有相关的依赖项，包括flink-rpc-core、flink-streaming-java和flink-clients等包都已正确引入在升级Flink版本时，要特别注意依赖关系的变化，确保所有相关的依赖项都与新版本的Flink兼容
    2. 检查类路径：这个错误可能是由于类路径中缺少某些必要的类文件确保你的项目构建和运行时使用的类路径中包含了所有必需的Flink库
    3. 检查版本兼容性：在升级Flink版本时，要特别注意版本兼容性问题查看Flink文档和相关日志，确保你升级的版本之间没有重大的不兼容性
    4. 清理缓存：有时候，旧的缓存数据可能导致升级失败你可以尝试清理Flink的相关缓存，然后重新构建和运行项目
    5. 查找社区支持：如果上述方法都无法解决问题，可以尝试在Flink的社区或论坛中寻求帮助社区中可能有其他人遇到了类似的问题，并且已经找到了解决方案

    以下是一个示例的Maven依赖项，供你参考：

    <dependencies>        <dependency>        <groupId>org.apache.flinkgroupId>        <artifactId>flink-coreartifactId>        <version>1.17.0version>    dependency>    <dependency>        <groupId>org.apache.flinkgroupId>        <artifactId>flink-streaming-java_2.12artifactId>        <version>1.17.0version>    dependency>        dependencies>
    已喜欢 已反对

  2. 当您遇到升级 Flink 版本时报 RpcLoaderException: Could not load RpcSystem 错误时，请采取如下措施：

    • 检查 flink-streaming-java 包是否缺失，如果有缺失，请补充安装和添加依赖；
    • 确保客户端环境相同，包括 JVM 版本和网络环境；
    • 清除本地缓存，并重新编译和打包；
    • 若仍无法解决问题，请尝试回退到旧版本，并重新安装所需的依赖包。
    已喜欢 已反对

  3. 确包
    org.apache.flink
    flink-rpc-akka
    1.17.1

    org.apache.flink
    flink-rpc-akka-loader
    1.17.1
    此回答整理自钉群“【②群】Apache Flink China社区”

    已喜欢 已反对