scala - Spark Streaming Twitter 示例：使用 TwitterUtils.createStream 时出现 NoClassDefFoundError

Question

我正在尝试实施http://ampcamp.berkeley.edu/big-data-mini-course/realtime-processing-with-spark-streaming.html或http://www.pwendell.com/2013/09/ 28/declarative-streams.html（虽然这使用了过时的 Spark 版本），但我一直以：

线程“主”java.lang.NoClassDefFoundError 中的异常：org/apache/spark/streaming/dstream/NetworkInputDStream

下面是一些导致问题的示例代码：

val ssc = new StreamingContext("local[12]", "Twitter Downloader", Seconds(30))

//causes the error
val tweets = TwitterUtils.createStream(ssc, None)

另外，我正在使用 Scala 和 Eclipse

谢谢！（如果有帮助，我可以打印更多错误或输出）

Answer 1

已解决——使用的是 .9 版本的 Spark-streaming-twitter（.jar 文件）而不是 1.02