NoClassDefFoundError: org/apache/flink/metrics/MetricGroup
碰到這么個(gè)問(wèn)題:
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/metrics/MetricGroup
?? ?at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1614)
?? ?at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(StreamExecutionEnvironment.java:975)
?? ?at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(StreamExecutionEnvironment.java:945)
?? ?at Map.main(Map.java:22)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.metrics.MetricGroup
?? ?at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
?? ?at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
?? ?at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
?? ?at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
?? ?... 4 more
顯然首先去$FLINK_HOME下面輸入
grep -r?MetricGroup
返回結(jié)果是:
flink-dist_2.11-1.12-SNAPSHOT.jar
在mvnrepository.com中搜不到flink-dist
實(shí)在沒(méi)辦法了,卡了老久,最后一個(gè)辦法如下 :
直接在Project Structure中導(dǎo)入$FLINK_HOME/lib下面的flink-dist-***.jar
然后再次運(yùn)行代碼,問(wèn)題解決.
?
總結(jié)
以上是生活随笔為你收集整理的NoClassDefFoundError: org/apache/flink/metrics/MetricGroup的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: flink的checkpoint实验-s
- 下一篇: 计算机中用于存放下一条要执行指令的地址的