Hi, I wrote a very simple program in scala to convert an existing RDD to SchemaRDD. But createSchemaRDD function is throwing exception
Exception in thread "main" scala.ScalaReflectionException: class org.apache.spark.sql.catalyst.ScalaReflection in JavaMirror with primordial classloader with boot classpath [.....] not found Here's more info on the versions I am using - <scala.binary.version>2.11</scala.binary.version> <spark.version>1.2.1</spark.version> <scala.version>2.11.5</scala.version> Please let me know how can I resolve this problem. Thanks Ashish