py4j.protocol.Py4JJavaError: An error occurred while calling o29.load. : org.apache.spark.SparkClassNotFoundException: [DATA_SOURCE_NOT_FOUND] Failed to find the data source: mongodb

Gigih_Haryo_Yudhanto · 2023-07-22T19:51:39.147Z

i run data pipelines in airflow gcp using pyspark, it was running perfectly before but suddenly the py4j.protocol.Py4JJavaError: An error occurred while calling o29.load.
: org.apache.spark.SparkClassNotFoundException: [DATA_SOURCE_NOT_FOUND] Failed to find the data source: mongodb appears. is there any new updates about mongodb spark connector? i get more confused when i run it in dataproc, it runs perfectly

Prakul_Agarwal · 2023-08-31T01:22:49.519Z

Which version of mongoDB Spark Connector are you using? This error seems to be stemming from the missing Spark connector in the environment. How are you including the Spark connector - is it installed in the environment or something you are passing when invoking the Spark execution?

Since you mentioned that the pipeline runs perfectly on Dataproc, but not on other environments, there might be a difference in the cluster configurations. Compare the configuration of your Dataproc cluster to the other Spark environment where you are encountering issues. Pay attention to the Spark version, the installed libraries, and the classpath configurations.

lamia_khalil · 2024-07-05T13:26:49.824Z

i have the same problem, you have any resolve for this issue