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 を使用しています。
ありがとう!(役立つ場合は、エラーまたは出力の詳細を印刷できます)