我在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
- 2022-04-24 10:13回答 1 已采纳 多个节点，同时获取到了数据，几个节点就有几次
- 2022-09-16 15:36回答 1 已采纳 那就 sudo ./start-cluster.sh
- 2022-03-31 18:25打酱油的葫芦娃的博客 本文的Flink源码版本为: 1.15-SNAPSHOT，读者可自行从Github clone. Flink 程序看起来像一个转换 DataStream 的...StreamExecutionEnvironment 是所有 Flink 程序的基础。 创建 你可以使用 StreamExecutionEnvironme.
- 2023-02-01 10:55回答 4 已采纳 题主的思路完全正确可行，因为我就是这么做的。也是一开始觉得不是很正规，但确实能解决实际的业务问题，要相信自己。 梳理一下BaseJar：丢到linux服务器上，用来解析Flink SQL语句MySQ
- 2021-03-31 22:25保护我方胖虎的博客 注：本篇章的flink学习均是基于java开发语言 我们如果要使用flink进行计算开发，一个完整的开发步骤是怎样的呢？ 前情回顾：什么叫有界数据流，什么叫无界数据流（何为流处理，何为批处理）？ - Batch Analytics，...
- 2021-04-12 22:55张伯毅的博客 前言 StreamExecutionEnvironment类表示运行一个Flink任务所需的环境，分为本地LocalStreamEnvironment和远RemoteStreamEnvironment两种。 LocalStreamEnvironment : 在当前JVM环境中运行 RemoteStreamEnvironment :...
- 没有解决我的问题, 去提问
悬赏问题
- ¥15 SPSS分类模型实训题步骤
- ¥15 求解决扩散模型代码问题
- ¥15 工创大赛太阳能电动车项目零基础要学什么
- ¥20 limma多组间分析最终p值只有一个
- ¥15 nopCommerce开发问题
- ¥15 torch.multiprocessing.spawn.ProcessExitedException: process 1 terminated with signal SIGKILL
- ¥15 QuartusⅡ15.0编译项目后，output_files中的.jdi、.sld、.sof不更新怎么解决
- ¥15 pycharm输出和导师的一样，但是标红
- ¥15 想问问富文本拿到的html怎么转成docx的
- ¥15 我看了您的文章，遇到了个问题。