Minimal Spark + SnakeYAML test

build.sbt

name := "SparkSnakeYamlTest"

version := "1.0"

scalaVersion := "2.11.7"

libraryDependencies += "org.apache.spark" %% "spark-core" % "2.0.0"
libraryDependencies += "org.yaml"         %  "snakeyaml"  %  "1.17"

Main.scala

import org.apache.spark.SparkContext
import org.apache.spark.SparkContext._
import org.apache.spark.SparkConf

import org.yaml.snakeyaml.Yaml
import org.yaml.snakeyaml.constructor.Constructor
import scala.collection.mutable.ListBuffer
import scala.beans.BeanProperty

object Main {

  class EmailAccount {
    @scala.beans.BeanProperty var accountName: String = null

    override def toString: String = {
      return s"acct ($accountName)"
    }
  }

  def main(args: Array[String]) {
    val conf = new SparkConf().setAppName("SparkSnakeYamlTest")
    val sc = new SparkContext(conf)

    val text = """accountName: Ymail Account"""

    val yaml = new Yaml(new Constructor(classOf[EmailAccount]))
    val e = yaml.load(text).asInstanceOf[EmailAccount]
    println(e)

    sc.stop()
  }

}

See http://stackoverflow.com/questions/38002883/snakeyaml-and-spark-results-in-an-inability-to-construct-objects/40688619#40688619