scala - 带有 Spark 2.2.1 的 Scala .par 函数给出 Janino 编译错误

Question

我有一些如下代码。

def computeGroupByCount(Columns: List[String], DF: DataFrame): List[JsValue] = {

  val result: ListBuffer[JsValue] = new ListBuffer[JsValue]()
  val encoder: Encoder[ColumnGroupByCount] = Encoders.product[ColumnGroupByCount]

  groupByCountColumns.par.foreach(colName => {
    val groupByCount: Array[ColumnGroupByCount] = DF
      .groupBy(colName)
      .count()
      .map(x => ResponseOnGroupByCount(colName.toString, x.getString(0), x.getLong(1)))(encoder)
      .collect()
    result += Json.toJson(groupByCount)
  })
  result.toList
}

当我运行此代码时，它给出以下错误。但它在 IntelliJ 中工作

[info]   Cause: org.codehaus.janino.InternalCompilerException: Class 'org.apache.spark.sql.catalyst.expressions.codegen.GeneratedClass' was loaded through a different loader

并抛出奇怪的代码错误

请帮助我。