sql >> Databasteknik >  >> NoSQL >> MongoDB

MongoDB Spark Connector py4j.protocol.Py4JJavaError:Ett fel uppstod när o50.load anropades

Jag kom på svaret på min fråga. Detta var ett kompatibilitetsproblem med Mongo-Spark-kontakten och versionen av Spark som jag uppgraderade till. Specifikt ändrades värdet findTightestCommonTypeOfTwo i PR:

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

För Spark 2.2.0 är den kompatibla Mongo-Spark-kontakten också 2.2.0, så i mitt exempel skulle paketet laddas så här:

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

Detta kan ändras i framtiden, så när du använder kontakten bör du kontrollera kompatibilitet med den version av Spark som används.




  1. Metod fungerar i utveckling men inte produktion Rails MongoDB

  2. Ångra convertToCapped till en samling

  3. MongoRepository dynamiska frågor

  4. Mongo:Hur grupperar jag efter $vecka men returnerar startdatum och slutdatum för varje vecka istället?