栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

flink启动报错:java.lang.NoClassDefFoundError: scala/collection/immutable/StringOps 解决方法

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

flink启动报错:java.lang.NoClassDefFoundError: scala/collection/immutable/StringOps 解决方法

Exception in thread "main" java.lang.NoClassDefFoundError: scala/collection/immutable/StringOps
    at org.apache.flink.runtime.akka.AkkaUtils$.testDispatcherConfig(AkkaUtils.scala:374)
    at org.apache.flink.runtime.akka.AkkaUtils.testDispatcherConfig(AkkaUtils.scala)
    at org.apache.flink.runtime.minicluster.MiniCluster.createLocalRpcService(MiniCluster.java:951)
    at org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:288)
    at org.apache.flink.client.program.PerJobMiniClusterFactory.submitJob(PerJobMiniClusterFactory.java:75)
    at org.apache.flink.client.deployment.executors.LocalExecutor.execute(LocalExecutor.java:85)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1957)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1848)
    at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:69)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1834)
    at cn.flink.JavaDataStreamApp.main(JavaDataStreamApp.java:13)
Caused by: java.lang.ClassNotFoundException: scala.collection.immutable.StringOps
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:355)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
    ... 11 more

解决方法:

默认pom.xml中,scala版本为2.11


    org.apache.flink
    flink-streaming-java_${scala.binary.version}
    ${flink.version}
    compile


    org.apache.flink
    flink-clients_${scala.binary.version}
    ${flink.version}
    compile

查看当前工程中安装的scala版本,是否匹配。如果不存成,就安装匹配的scala 版本

 

 

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/295624.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号