Flink Java 运行WordCount程序报错

pom.xml 主要配置如下：

    <dependency>
      <groupId>org.apache.flink</groupId>
      <artifactId>flink-java</artifactId>
      <version>1.13.6</version>
      <scope>provided</scope>
    </dependency>
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-log4j12</artifactId>
      <version>1.7.36</version>
      <scope>provided</scope>
    </dependency>

在运行wordcount时报以下错误
"C:\Program Files\Java\jdk1.8.0_291\bin\java.exe" "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2020.3.4\lib\idea_rt.jar=55423:C:\Program Files\JetBrains\IntelliJ IDEA 2020.3.4\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_291\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_291\jre\lib\rt.jar;C:\Users\Administrator.m2\repository\org\apache\flink;C:\Users\Administrator.m2\repository\org\apache\flink\flink-clients_2.12\1.9.2\flink-clients_2.12-1.9.2.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-clients_2.12\1.9.2\flink-clients_2.12-1.9.2-sources.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-clients_2.12\1.9.2\flink-clients_2.12-1.9.2-javadoc.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-core\1.10.0\flink-core-1.10.0.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-hadoop-fs\1.10.0\flink-hadoop-fs-1.10.0.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-java\1.10.0\flink-java-1.10.0.jar;C:\Users\Administrator.m2;C:\Apache\flink-1.14.0\lib\flink-csv-1.14.0.jar;C:\Apache\flink-1.14.0\lib\flink-dist_2.11-1.14.0.jar;C:\Apache\flink-1.14.0\lib\flink-json-1.14.0.jar;C:\Apache\flink-1.14.0\lib\flink-shaded-zookeeper-3.4.14.jar;C:\Apache\flink-1.14.0\lib\flink-table_2.11-1.14.0.jar;D:\hadoop-3.2.2\share\hadoop\client;D:\hadoop-3.2.2\share\hadoop\common;D:\hadoop-3.2.2\share\hadoop\hdfs;D:\hadoop-3.2.2\share\hadoop\mapreduce;D:\hadoop-3.2.2\share\hadoop\tools;D:\hadoop-3.2.2\share\hadoop\yarn;C:\Users\Administrator\selfstudy-flink\target\classes;C:\Apache\flink-1.9.1\lib\flink-dist_2.12-1.9.1.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-java\1.13.6\flink-java-1.13.6.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-core\1.13.6\flink-core-1.13.6.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-annotations\1.13.6\flink-annotations-1.13.6.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-metrics-core\1.13.6\flink-metrics-core-1.13.6.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-shaded-asm-7\7.1-13.0\flink-shaded-asm-7-7.1-13.0.jar;C:\Users\Administrator.m2\repository\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;C:\Users\Administrator.m2\repository\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;C:\Users\Administrator.m2\repository\org\objenesis\objenesis\2.1\objenesis-2.1.jar;C:\Users\Administrator.m2\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;C:\Users\Administrator.m2\repository\org\apache\commons\commons-compress\1.21\commons-compress-1.21.jar;C:\Users\Administrator.m2\repository\org\apache\flink\flink-shaded-guava\18.0-13.0\flink-shaded-guava-18.0-13.0.jar;C:\Users\Administrator.m2\repository\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;C:\Users\Administrator.m2\repository\org\apache\commons\commons-math3\3.5\commons-math3-3.5.jar;C:\Users\Administrator.m2\repository\org\slf4j\slf4j-api\1.7.15\slf4j-api-1.7.15.jar;C:\Users\Administrator.m2\repository\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;C:\Users\Administrator.m2\repository\org\apache\flink\force-shading\1.13.6\force-shading-1.13.6.jar;C:\Users\Administrator.m2\repository\org\slf4j\slf4j-reload4j\1.7.36\slf4j-reload4j-1.7.36.jar;C:\Users\Administrator.m2\repository\ch\qos\reload4j\reload4j\1.2.19\reload4j-1.2.19.jar" com.selfstudy.BatchJob
[org.apache.flink.api.java.ExecutionEnvironment]-The job has 0 registered types and 0 default Kryo serializers
[org.apache.flink.api.java.ExecutionEnvironment]-Registered Kryo types: []
[org.apache.flink.api.java.ExecutionEnvironment]-Registered Kryo with Serializers types: []
[org.apache.flink.api.java.ExecutionEnvironment]-Registered Kryo with Serializer Classes types: []
[org.apache.flink.api.java.ExecutionEnvironment]-Registered Kryo default Serializers: []
[org.apache.flink.api.java.ExecutionEnvironment]-Registered Kryo default Serializers Classes []
[org.apache.flink.api.java.ExecutionEnvironment]-Registered POJO types: []
[org.apache.flink.api.java.ExecutionEnvironment]-Static code analysis mode: DISABLE
Exception in thread "main" java.lang.AbstractMethodError: org.apache.flink.client.deployment.executors.LocalExecutor.execute(Lorg/apache/flink/api/dag/Pipeline;Lorg/apache/flink/configuration/Configuration;)Ljava/util/concurrent/CompletableFuture;
at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:944)
at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:860)
at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:844)
at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
at com.selfstudy.BatchJob.main(BatchJob.java:28)

Process finished with exit code 1
麻烦指点，谢谢

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除
收藏举报

2条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
吕布辕门后端领域新星创作者 2022-04-11 08:14
关注
本地执行需要去掉，依赖范围provided，可以查看我的微博，flink专栏

本回答被题主选为最佳回答 , 对您是否有帮助呢?

解决
无用 1
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

查看更多回答(1条)

报告相同问题？

关注问题

Flink Java 运行WordCount程序报错 flink java 有问必答
2022-04-04 22:57

回答 2 已采纳本地执行需要去掉，依赖范围provided，可以查看我的微博，flink专栏
flinksql读取kafka数据报错 flink kafka
2022-07-13 20:33

回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
flink独立集群运行报错 flink
2021-07-28 13:39

回答 1 已采纳 /tmp目录是flink默认的临时文件目录。这三个参数的目录指定未自己创建的目录，给权限。state.checkpoints.dirstate.savepoints.dirio.tmp.dirs
Flink基础系列8-Flink on yarn运行wordcount程序
2021-10-15 10:27

只是甲的博客文章目录环境介绍一.Maven配置二.Java代码编写三.Maven打包并上传四.运行jar文件五.运行其它的class文件参考环境介绍测试服务器CDH 6.3.1版本安装Flink 1.9版本。 hello.txt文件 hello word hello hdfs hello ...
写Flink入门WordCount报程序包找不到 ide java
2020-08-02 00:30

回答 1 已采纳 https://www.cnblogs.com/lurenjiashuo/p/hadoop-wordcount-class-not-found.html https://blog.csdn.net/
flink java的API和scala的API创建环境的区别 flink java scala 有问必答
2022-01-02 12:03

回答 2 已采纳 scala的换成 createRemoteEnvironment，getExecutionEnvironment只是其中一种方法
flink程序找不到StreamExecutionEnvironment flink java 有问必答
2021-07-08 17:53

回答 1 已采纳你的包导入错了。是这个import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
Flink: Wordcount应用程序报错：ClassNotFoundException: yarn
2023-08-16 22:10

抱紧大佬大腿不松开的博客 Flink: Wordcount应用程序报错：ClassNotFoundException: yarn.exceptions.YarnException 大数据近年来，随着大数据技术的快速发展，人们对于处理海量数据的需求也日益增长。Apache Flink作为一种流式计算框架，在大...
Flink SQL查询报错 flink hive sql
2021-12-03 11:35

回答 2 已采纳找不到方法一般是打包时缺少该jar包，或者jar冲突。jar 冲突时，可以exclude其中一个jar依赖或者重新打包flink-hive-connector 通过 maven 插件重命名guava
一用到java的java.time.Duration时候就报错 flink java kafka
2022-12-11 14:26

回答 1 已采纳提示写的很清楚了，他需要的入参是Map类型的，你提供的是 Duration类型
flink多jobmanager运行重复输出问题 flink java spark
2022-04-24 10:13

回答 1 已采纳多个节点，同时获取到了数据，几个节点就有几次
Flink java wordcount
2020-12-10 13:21

柳牧之的博客 Flnk java wordcount前言项目的目录结构pom文件WindowWordCount.javahelloword.txt文件运行结果注意前言各位好，欢迎浏览我的博客，后面将持续更新小编在flink上学习的心得体会，希望越来越多的新同学加入到这个...
Java-flink的sum方法输出 flink
2022-06-05 15:31

回答 1 已采纳我的打印出来了，，，我代码是这样的 import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.
Flink WordCount 报错
2019-10-22 15:43

weixin_43843739的博客 Flink WordCount JavaAPI（从文件读取）图中，data目录下是要读取的文件：words 内容： hello java hello spark hello spark hello spark hello flink hello flink hello flink hello flink hello hadoop hello ...
IDEA本地运行Flink-java版
2022-05-04 23:53

fir_dameng的博客 jdk1.8+ 即可 ,因为flink 大部分是Java编写的 2.2 创建idea项目和普通的创建maven java项目一样，没有区别 2.3 pom.xml配置 <?xml version="1.0" encoding="UTF-8"?> <project xmlns=...
没有解决我的问题, 去提问

问题事件

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
系统已结题 5月4日
关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
已采纳回答 4月26日
关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
创建了问题 4月4日

悬赏问题

¥15 一个服务器已经有一个系统了如果用usb再装一个系统，原来的系统会被覆盖掉吗
¥15 使用esm_msa1_t12_100M_UR50S蛋白质语言模型进行零样本预测时，终端显示出了sequence handled的进度条，但是并不出结果就自动终止回到命令提示行了是怎么回事：
¥15 前置放大电路与功率放大电路相连放大倍数出现问题
¥30 关于<main>标签页面跳转的问题
¥80 部署运行web自动化项目
¥15 腾讯云如何建立同一个项目中物模型之间的联系
¥30 VMware 云桌面水印如何添加
¥15 用ns3仿真出5G核心网网元
¥15 matlab答疑关于海上风电的爬坡事件检测
¥88 python部署量化回测异常问题

Flink Java 运行WordCount程序报错

2条回答 默认 最新

问题事件

悬赏问题

2条回答默认最新