您应该使用外部类作为

class MyRegistrator extends KryoRegistrator {
override def registerClasses(kryo: Kryo) {
kryo.register(classOf[Array[org.apache.spark.sql.catalyst.InternalRow]])
}
}

资料来源：http://spark.apache.org/docs/0.6.0/tuning.html
或者如果你想注册你的spark班

val cls: Class[Array[InternalRow]] = classOf[Array[org.apache.spark.sql.catalyst.InternalRow]]

spark.sparkContext.getConf.registerKryoClasses(Array(cls))

我用第一个，效果很好，我还没有测试过第二个。