sql >> データベース >  >> NoSQL >> MongoDB

MongoDB Spark Connector py4j.protocol.Py4JJavaError:o50.loadの呼び出し中にエラーが発生しました

    私は自分の質問に対する答えを見つけました。これは、Mongo-SparkコネクタとアップグレードしたSparkのバージョンとの互換性の問題でした。具体的には、findTightestCommonTypeOfTwo値はPRで名前が変更されました:

    https://github.com/apache/spark/pull/16786/files

    Spark 2.2.0の場合、互換性のあるMongo-Sparkコネクタも2.2.0であるため、私の例では、パッケージは次のようにロードされます。

    --packages org.mongodb.spark:mongo-spark-connector_2.11:2.2.0\
    

    これは将来変更される可能性があるため、コネクタを使用するときは、使用しているSparkのバージョンとの互換性を確認する必要があります。




    1. MongoError:最初の接続時にサーバー[localhost:27017]に接続できませんでした

    2. ある範囲にわたるMongoDB集約

    3. MongoDB:静的な値を持つ集計$project追加フィールド

    4. Meteorアプリの環境変数