IDEA上运行Spark Streaming的问题总结

1.IDEA上的SparkStreaming程序中出现: NoClassDefFoundError: org/apache/spark/streaming/StreamingContext
环境:spark-2.2.2 + java-1.8 + scala-2.11;
解决:把pom.xml中的SparkStreaming maven 包中的<scope>provide</scope>去掉即可。

2.SparkStreaming 基础上运行 flume直接sink到到SparkStreaming时,使用Maven中spark-streaming-flume在虚拟机上跑的问题:
解决1:把Maven中的spark-streaming-flume包加上<scope>provide</scope>一行即可
解决2:在运行spark-submit 时,添加一行 “ --package spark-streaming-flume_2.11.jar ” 即可(比较耗费时间,可能需要网络,并且每次都要导入)

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容