2

だから私はこの例を実行しようとしています https://github.com/plaa/mongo-spark/blob/master/src/main/scala/ScalaWordCount.scala

しかし、私はこのエラーが発生し続けます

 Exception in thread "main" java.lang.NoClassDefFoundError: com/mongodb/hadoop/MongoInputFormat
at ScalaWordCount$.main(ScalaWordCount.scala:27)

クラスを見つけるのに苦労している理由がわかりません。私はmavenでプロジェクトを構築しましたが、うまく構築されているようです。

      /usr/local/spark/bin/spark-submit \
--class ScalaWordCount \
--master local target/scalawordcount-0.0.1-SNAPSHOT.jar  \
    --jars /home/daniel/.m2/repository/org/mongodb/mongo-java-driver/2.12.3 \/mongo-java-driver-2.12.3.jar, \
    /home/daniel/mongo-hadoop/core/build/libs/mongo-hadoop-core-1.3.3-SNAPSHOT.jar

これは私がそれを実行するために使用しているコマンドです。ホームディレクトリ内で作業しています。前もって感謝します。

このチュートリアルhttps://github.com/crcsmnky/mongodb-spark-demoを使用して、Apache Sparkでmongodbをセットアップしました

PS iveは、新しいrealeseで修正されるクラスパスにバグがあることについてオンラインでいくつかのことを読みました...

4

1 に答える 1

1

ofへのjarsパスを追加するだけです。私はそれが良い解決策ではないことを知っていますが、うまくいきます。spark-env.shSPARK_CLASSPATH

于 2015-07-25T07:38:14.377 に答える