我在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
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏举报 分享
- 2021-07-08 17:53回答 1 已采纳 你的包导入错了。是这个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-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...
- 2021-07-07 12:51回答 1 已采纳 看报错提示：No match found for function signature instr (, )你是不是用了中文下的逗号。
- 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只是其中一种方法
- 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
- 2023-02-01 10:55回答 4 已采纳 题主的思路完全正确可行，因为我就是这么做的。也是一开始觉得不是很正规，但确实能解决实际的业务问题，要相信自己。 梳理一下BaseJar：丢到linux服务器上，用来解析Flink SQL语句MySQ
- 2022-04-24 10:13回答 1 已采纳 多个节点，同时获取到了数据，几个节点就有几次
- 2021-04-12 22:55张伯毅的博客 前言 StreamExecutionEnvironment类表示运行一个Flink任务所需的环境，分为本地LocalStreamEnvironment和远RemoteStreamEnvironment两种。 LocalStreamEnvironment : 在当前JVM环境中运行 RemoteStreamEnvironment :...
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 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.
- 没有解决我的问题, 去提问
悬赏问题
- ¥15 关于#matlab#的问题：在模糊控制器中选出线路信息，在simulink中根据线路信息生成速度时间目标曲线（初速度为20m/s，15秒后减为0的速度时间图像）我想问线路信息是什么
- ¥15 banner广告展示设置多少时间不怎么会消耗用户价值
- ¥16 mybatis的代理对象无法通过@Autowired装填
- ¥15 可见光定位matlab仿真
- ¥15 arduino 四自由度机械臂
- ¥15 wordpress 产品图片 GIF 没法显示
- ¥15 求三国群英传pl国战时间的修改方法
- ¥15 matlab代码代写，需写出详细代码，代价私
- ¥15 ROS系统搭建请教（跨境电商用途）
- ¥15 AIC3204的示例代码有吗，想用AIC3204测量血氧，找不到相关的代码。