Closed bhoppi closed 8 years ago
Great. Please share here the root cause analysis and the corresponding fix.
The Spark conf setting "spark.kryo.classesToRegister" does not work. We call:
val conf: SparkConf
conf.registerKryoClasses(Array(classOf[BSV], classOf[BDV], ...))
which works.
It is done.