Apacheflink作业在启动集群时崩溃,出现异常java.lang.IllegalAccessError:classorg.apache.flink.util.NetUtils。
创始人
2024-09-05 20:01:02
0次

这个问题通常是由于不同版本的flink客户端和集群之间的不兼容导致的。要解决此问题,需要确保flink客户端和flink集群使用相同的版本。另外,可以尝试将flink相关的jar文件放入作业的classpath中,以确保正确的jar文件被使用。

以下是一个示例,如何在flink客户端中运行作业:

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.util.Collector;

public class WordCount {

    public static void main(String[] args) throws Exception {

        final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        env.fromElements("hello world", "hello flink", "hello flink")
                .flatMap(new FlatMapFunction>() {
                    @Override
                    public void flatMap(String value, Collector> out) {
                        for (String word : value.split("\\s")) {
                            out.collect(new Tuple2<>(word, 1));
                        }
                    }
                })
                .groupBy(0)
                .sum(1)
                .print();

    }
}

在这个示例中,我们运行一个简单的word count作业。要确保正确的flink库被使用,可以通过将flink的依赖包添加到pom.xml文件中来实现。例如,添加以下依赖项:


    org.apache.flink
    flink-java
    1.11.2


    org.apache.flink
    flink-clients_2.11
    1.11.2

这样就可以确保正确的flink库被使用,以避免java.lang.IllegalAccessError错误。

相关内容

热门资讯

黑科技教程!德普之星透视辅助插... 德普之星透视辅助插件AI 游戏攻略黑科技上线本地缓存功能,离线查阅能力开挂。提前下载对应游戏攻略数据...
热点推荐!德扑之星辅助器怎么用... 『标题:当前标题』主打赛后复盘的 AI 游戏攻略黑科技走红,对局总结能力开挂。上传对局回放或者战绩截...
解说技巧!wpk辅助器是真的吗... 本地部署 AI 黑科技工具迎来新版本,不用上传文件到云端就能完成wpk辅助器是真的吗解析、 AI 处...
今日百科!WPK多开,德扑之星... 一款 AI 游戏攻略黑科技工具上线,查攻略效率直接开挂。它整合版本更新、装备搭配、BOSS 打法、牌...
一分钟揭秘!!wepoker网... 很多人使用云端 AI 时,都担心wepoker网页版透视方法、内部资料上传带来隐私风险。这款本地运行...
大神推荐!如何下载wepoke... 本地部署 AI 黑科技工具迎来新版本,不用上传文件到云端就能完成如何下载wepoker安装包解析、 ...
重大发现!wepoker破解版... wepoker破解版内购AI 游戏攻略黑科技上线本地缓存功能,离线查阅能力开挂。提前下载对应游戏攻略...
推荐攻略!wpk透视脚本,德普... 推荐攻略!wpk透视脚本,德普之星透视软件神器(从前是真的有辅助器)AI 是一款可以让一直输的玩家修...
热点推荐!wpk作弊,微扑克可... 您好,热点推荐!wpk作弊,微扑克可以开挂吗教程(从来真的是有开挂)这款游戏可以开挂的,确实是有挂的...
攻略讲解!wpk俱乐部是做什么... 您好,攻略讲解!wpk俱乐部是做什么的,德普之星开挂透视教程插件(本然有透视挂)这款游戏可以开挂的,...