mongodb - 如何根据 Spark SQL 中的 DBRef 字段列表进行查询

Question

我有一个包含 DBRef 对象列表的 mongo 数据库。我正在将此集合转换为 spark 中的数据框。

这给出了以下错误。有谁知道如何解决这个错误？？

编辑:: 转换为数据框会出现以下错误-> org.codehaus.janino.InternalCompilerException: 两个非抽象方法“public int scala.collection.TraversableOnce.size()”具有相同的参数类型，声明类型和返回类型

标签： mongodbapache-spark-sqlspark-streamingspark-java

Answer 1

将“org.codehaus.janino”的版本升级到 3.0.9（之前我使用的是 3.0.8）后，该错误得到解决。