MongoDB 报错 Exception in thread "main" org.bson.BsonInvalidOperationException: Document does not contain key avgObjSize

Question

出问题的代码段：
val simMovieMatrix = spark.read
.option("uri", mongoConfig.uri)
.option("collection", MONGODB_MOVIE_RECS_COLLECTION)
.format("com.mongodb.spark.sql")
.load()
.as[MovieRecs]
.rdd
.map{ movieRecs => // 为了查询相似度方便，转换成map
(movieRecs.mid, movieRecs.recs.map( x=> (x.mid, x.score) ).toMap )
}.collectAsMap()

Answer 1

问题解决了吗？我也遇到了这个问题，求指教