MongoDB
 sql >> Baza danych >  >> NoSQL >> MongoDB

MongoDB Spark Connector py4j.protocol.Py4JJavaError:Wystąpił błąd podczas wywoływania o50.load

Znalazłem odpowiedź na moje pytanie. Był to problem ze zgodnością ze złączem Mongo-Spark i wersją Spark, do której uaktualniłem. W szczególności zmieniono nazwę wartości findTightestCommonTypeOfTwo w PR:

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

Dla Spark 2.2.0 kompatybilnym złączem Mongo-Spark jest również 2.2.0, więc w moim przykładzie pakiet zostałby załadowany tak:

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

Może się to zmienić w przyszłości, więc podczas korzystania z łącznika należy sprawdzić zgodność z używaną wersją Sparka.




  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Mongoid / Mongodb i odpytywanie osadzonych dokumentów

  2. Pobierz dane z mongodb za pomocą sterownika C#

  3. Filtruj według daty za pomocą idObject

  4. Liczba elementów MongoDB w tablicy

  5. sortowanie agregacji mongodb