如何修复由java.net.sockettimeoutexception引起的mongotimeoutexception:连接超时

6tr1vspr  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(305)

我试图将Dataframe保存到mongodb,如下所示:

write_format = dataframe.write.format("com.mongodb.spark.sql.DefaultSource").mode(mode)
host = write_format.option("uri", db_host)
database = option_host.option("database", dbs_config.database)
collection = option_database.option("collection", collection)
collection.save()

并获取由java.net.sockettimeoutexception引起的以下错误:

com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting to connect. Client view of cluster state is {type=UNKNOWN, servers=[{address=atlas-marketing.fiverrdev.com:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSocketOpenException: Exception opening socket}, caused by {java.net.SocketTimeoutException: connect timed out}}]

你能建议一下要检查什么来解决这个问题吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题