【发布时间】:2019-12-02 02:58:30
【问题描述】:
我添加了以下依赖项。当我将 spark-streaming_2.12 更改为 spark-streaming_2.11 时,会出现此错误
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/streaming/StreamingContext
这些是我的依赖项:
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming_2.12</artifactId>
<version>2.4.0</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_2.11</artifactId>
<version>2.4.0</version>
</dependency>
我的代码:
def main(args: Array[String]): Unit = {
val conf = new SparkConf().setAppName("LogProcessor")
// No need to create sparkContext as StreamingContext itself create one
val streamer = new StreamingContext(conf,Seconds(20))
val lines = streamer.textFileStream("/home/ubuntu/Desktop/test/")
println(lines)
}
【问题讨论】:
-
我收到此错误 --> 线程“main” java.lang.NoClassDefFoundError: org/apache/spark/streaming/StreamingContext 中的异常
-
请提供有关您如何执行应用程序(以及在何处执行)的更多信息。此外,一个完整的 pom 会很有帮助。您是否正在创建一个包含所有依赖项的 uber jar?
标签: scala maven apache-spark spark-streaming