开发者社区> 问答> 正文

第一个flink的WordCount程序运行时错误,

错误:

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/environment/StreamExecutionEnvironment

at test.FlinkTest.main(FlinkTest.java:16)

Caused by: java.lang.ClassNotFoundException: org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

就是这里错了:

'StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();'

maven依赖有添加,不知道怎么回事

展开
收起
游客h5pdq2cukapjg 2019-03-06 13:16:13 9077 0
2 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载