【发布时间】:2015-03-10 03:01:34
【问题描述】:
我正在尝试将 Spark Streaming 与 Scala 一起使用,但我遇到了错误,我不知道为什么。
StreamingContext 是给出错误的行:
val sparkConf = new SparkConf().setAppName("App_StreamingConsumer")
val ssc = new StreamingContext(sparkConf, Seconds(2))
这是两个错误:
错误的符号引用。 StreamingContext.class 中的签名是指 在不可用的包 org.apache.hadoop 中使用术语 conf。它 当前类路径或版本中可能完全缺失 类路径上的可能与使用的版本不兼容 编译 StreamingContext.class。
还有:
加载类文件时检测到缺少或无效的依赖项 'StreamingContext.class'。无法访问包中的术语 conf org.apache.hadoop,因为它(或其依赖项)丢失了。查看 缺少或冲突的依赖项的构建定义。 (重新运行 使用 -Ylog-classpath 查看有问题的类路径。)完全重建 如果 'StreamingContext.class' 是针对 org.apache.hadoop 版本不兼容。
之前有人问过这个问题: Spark Streaming StreamingContext error 错误似乎来自依赖问题,但据我所知,我的依赖都正常。
【问题讨论】:
标签: scala spark-streaming