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

MongoDB 报错 Exception in thread

问题描述:

出问题的代码段:
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()

问题解决了吗?我也遇到了这个问题,求指教