Jose_Maria_Tala
New Contributor II

val conf = new SparkConf()

...

conf.set("spark.kryoserializer.buffer.max.mb", "512")

...