私は、reactivemongo コネクタを介して MongoDB とやり取りする Spark Streaming アプリケーションに取り組んできました。ただし、Spark ジョブで次の例外が発生しています
16:53:23.153 [ForkJoinPool-4-worker-5] ERROR reactivemongo.api.Failover2 - Got an error, no more attempts to do. Completing with a failure... reactivemongo.core.errors.ConnectionNotInitialized: MongoError['Connection is missing metadata (like protocol version, etc.) The connection pool is probably being initialized.'] at reactivemongo.core.errors.ConnectionNotInitialized$.MissingMetadata(errors.scala:67)
この例外のデバッグに関するオンライン リファレンスが見つかりませんでした。誰もこれに遭遇したことがありますか？もしそうなら、この例外をスローする可能性のあるものについてのアイデアはありますか?
私のコードのスニペット:
...
val driver = MongoDriver()
val connection = driver.connection(List("10.211.55.10"))
val db = connection("wordCountDB")
val collection = db[BSONCollection]("counts")
...
前もって感謝します