我在Eclipse编写的java的flink程序(最基础的wordcount实例)，在import中不能找到“org.apache.flink.api.environment.StreamExecutionEnvironment”这个类，我已经在依赖库中导入了flink/lib下的JAR包，但是没有效果。刚接触flink，求大神告知解决办法。
flink程序报错:"StreamExecutionEnvironment cannot be resolved"
flink程序找不到StreamExecutionEnvironment
- 写回答
- 好问题 0 提建议
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
- CSDN专家-sinJack 2021-07-08 18:09关注
你的包导入错了。是这个import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏举报 分享
- 2022-04-04 22:57回答 2 已采纳 本地执行需要去掉，依赖范围provided，可以查看我的微博，flink专栏
- 2020-08-02 00:30回答 1 已采纳 https://www.cnblogs.com/lurenjiashuo/p/hadoop-wordcount-class-not-found.html https://blog.csdn.net/
- 2021-07-07 12:51回答 1 已采纳 看报错提示：No match found for function signature instr (, )你是不是用了中文下的逗号。
- 2021-03-06 17:31许早早的博客 用“mvn clean package-Pbuild jar”命令构建了一个fat jar，并用“flink run-m yarn cluster-yn 2./flink-SNAPSHOT-1.0.jar”命令提交程序后，程序抛出以下异常：java.lang.NoClassDefFoundErr...
- 2022-06-05 15:31回答 1 已采纳 我的打印出来了，，，我代码是这样的 import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.
- 2022-01-02 12:03回答 2 已采纳 scala的换成 createRemoteEnvironment，getExecutionEnvironment只是其中一种方法
- 2022-09-16 15:36回答 1 已采纳 那就 sudo ./start-cluster.sh
- 2023-03-17 09:58开心编码的博客 flink任务通过读取配置的方式来运行程序，写好一个模板每次只需要通过修改配置文件重新压缩成jar之后即可。一定要配置resources目录，不然的话程序在flink中找不到properties文件。
- 2022-02-09 15:08回答 2 已采纳 在这里：https://github.com/apache/flink/tree/69d9fade5b0e3629c84548c06f0624e9e66fdefe/flink-connectors/f
- 2022-04-24 10:13回答 1 已采纳 多个节点，同时获取到了数据，几个节点就有几次
- 2021-09-02 17:59回答 2 已采纳 直接写消费者，行，也是实时计算。区别是spark这种功能比较多，比如多态机器分布部署，容错机制，故障恢复等。所以对于大型系统用spark这种更方便。如果系统的要求没那么高，那肯定是自己写比较方便了。
- 2021-03-31 22:25保护我方胖虎的博客 注：本篇章的flink学习均是基于java开发语言 我们如果要使用flink进行计算开发，一个完整的开发步骤是怎样的呢？ 前情回顾：什么叫有界数据流，什么叫无界数据流（何为流处理，何为批处理）？ - Batch Analytics，...
- 2022-03-31 18:25打酱油的葫芦娃的博客 本文的Flink源码版本为: 1.15-SNAPSHOT，读者可自行从Github clone. Flink 程序看起来像一个转换 DataStream 的...StreamExecutionEnvironment 是所有 Flink 程序的基础。 创建 你可以使用 StreamExecutionEnvironme.
- 2021-04-12 22:55张伯毅的博客 前言 StreamExecutionEnvironment类表示运行一个Flink任务所需的环境，分为本地LocalStreamEnvironment和远RemoteStreamEnvironment两种。 LocalStreamEnvironment : 在当前JVM环境中运行 RemoteStreamEnvironment :...
- 2022-04-12 10:56LemonCoder呀的博客 Java 开发flink 流/批处理程序 文章目录Java 开发flink 流/批处理程序一、安装`pom`依赖，配置打包插件以及入口类二、编写`Flink`程序三、完整的java代码四、测试 一、安装pom依赖，配置打包插件以及入口类 <?...
- 没有解决我的问题, 去提问
