确定哪个对象在Apache-Flink中不可序列化

我正在写一个Flink转换器，我有一个Histogram具有以下属性的自定义对象：

case class Histogram(
nRows: Int,
nCols: Int,
min: Int,
step: Double,
private val countMatrix: Array[ArrayBuffer[Double]],
private val cutMatrixL1: Array[ArrayBuffer[Double]],
val distribMatrixL1: Array[ArrayBuffer[Map[Int, Double]]],
private val distribMatrixL2: Array[ArrayBuffer[Map[Int, Double]]],
private val cutMatrixL2: ArrayBuffer[ArrayBuffer[Double]])
extends Serializable {

???

}
这是我的FitOperation：

implicit val fitOp = new FitOperation[PIDiscretizerTransformer, LabeledVector] {

override def fit(
                  instance: PIDiscretizerTransformer,
                  fitParameters: ParameterMap,
                  input: DataSet[LabeledVector]): Unit = {

  // get params...

  val metric = input.map { x ⇒
    // (instance, histrogram totalCount)
    (x, Histogram(nAttrs, l1InitialBins, min, instance.step), 1)
  }.reduce { (m1, m2) ⇒
    // Update Layer 1
    val updatedL1 = updateL1(m1._1, m1._2, instance.step, initialElems, alpha, m1._3)

    //         Update Layer 2 if neccesary
    val updatedL2 = if (m1._3 % l2updateExamples == 0) {
      updateL2(m1._1, updatedL1)
    } else updatedL1

    (m2._1, updatedL2, m1._3 + 1)
  }.map(_._2)

  //      instance.metricsOption = Some(metric)
}

}
这很好用，但如果我取消注释最后一行：instance.metricsOption = Some(metric)我得到一个java.io.NotSerializableException: org.apache.flink.api.scala.DataSet

我怎么能找到班上哪个Histogram类导致的问题？据我所知，ArrayBuffer可序列化，Map也是如此。虽然我发现了这个问题：

地图无法在scala中序列化？

这说明.mapValues不可序列化，但我没有.在任何地方使用mapValues。