启动spark streaming失败,报错为:
原因: java.lang.NoClassDefFoundError: org/apache/spark/api/java/function/FlatMapFunction
解决:
在pom.xml里面,原配置
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming_2.12</artifactId>
<version>3.2.1</version>
<scope>provided</scope>
</dependency>
的
**<scope>provided</scope>**
删掉即可。变为:
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming_2.12</artifactId>
<version>3.2.1</version>
</dependency>
版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : https://zhangphil.blog.csdn.net/article/details/124692064
内容来源于网络,如有侵权,请联系作者删除!