sql >> Databáze >  >> NoSQL >> MongoDB

MongoDB Spark Connector py4j.protocol.Py4JJavaError:Při volání o50.load došlo k chybě

Přišel jsem na odpověď na svou otázku. Jednalo se o problém s kompatibilitou s konektorem Mongo-Spark a verzí Spark, na kterou jsem upgradoval. Konkrétně hodnota findTightestCommonTypeOfTwo byla v PR přejmenována:

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

Pro Spark 2.2.0 je kompatibilní konektor Mongo-Spark také 2.2.0, takže v mém příkladu by se balíček načetl takto:

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

To by se mohlo v budoucnu změnit, takže při používání konektoru byste měli zkontrolovat kompatibilitu s používanou verzí Spark.




  1. Aktualizace hlubokého záznamu v MongoDb

  2. Jak mohu najít ID relace při použití Express / Connect a úložiště relací?

  3. Jak zrušit platnost částí hierarchie (stromu) dat v mezipaměti Redis

  4. Jak načíst data z MongoDB?