IDEA上运行Spark Streaming的问题总结

2019-04-06  本文已影响0人  joy悦_06e8

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 ” 即可(比较耗费时间,可能需要网络,并且每次都要导入)

上一篇下一篇

猜你喜欢

热点阅读