Here is the relevant snippet of code in my main program:


sparkConf.set("spark.kryo.registrationRequired", "true")
val summaryDataClass = classOf[SummaryData]
val summaryViewClass = classOf[SummaryView]
  summaryDataClass, summaryViewClass))
I get the following error:

Exception in thread "main" java.lang.reflect.InvocationTargetException

Caused by: org.apache.spark.SparkException: Failed to load class to register with Kryo

Caused by: java.lang.ClassNotFoundException: com.dtex.analysis.transform.SummaryData

Note that the class in question SummaryData is in the same package as the main program and hence in the same jar.

What do I need to do to make this work?