Kryo注册了LabeledPoint类

非常感谢@eliasah,他通过指出建议的解决方案(kryo.register(org.apache.spark.mllib.regression.LabeledPoint[].class);)Java在Scala而不在Scala 中,为这个答案做出了很多贡献.

因此,LabeledPoint[]Scala的意思是Array[LabeledPoint].

我通过注册Array[LabeledPoint]类解决了我的问题,即添加我的代码:

sc.getConf.registerKryoClasses(classOf[ Array[org.apache.spark.mllib.regression.LabeledPoint] ])