Error in SparkSQL/Scala IDE

[Sathish Kumaran Vairavelu]

Hi Everyone,

I am getting following error while registering table using Scala IDE.
Please let me know how to resolve this error. I am using Spark 1.2.1

  import sqlContext.createSchemaRDD



  val empFile = sc.textFile("/tmp/emp.csv", 4)

                  .map ( _.split(",") )

                  .map( row=> Employee(row(0),row(1), row(2), row(3), row(4
)))

  empFile.registerTempTable("Employees")

Thanks

Sathish

Exception in thread "main" scala.reflect.internal.MissingRequirementError:
class org.apache.spark.sql.catalyst.ScalaReflection in JavaMirror with
primordial classloader with boot classpath
[/Applications/eclipse/plugins/org.scala-ide.scala210.jars_4.0.0.201412161056/target/jars/scala-library.jar:/Applications/eclipse/plugins/org.scala-ide.scala210.jars_4.0.0.201412161056/target/jars/scala-reflect.jar:/Applications/eclipse/plugins/org.scala-ide.scala210.jars_4.0.0.201412161056/target/jars/scala-actor.jar:/Applications/eclipse/plugins/org.scala-ide.scala210.jars_4.0.0.201412161056/target/jars/scala-swing.jar:/Applications/eclipse/plugins/org.scala-ide.scala210.jars_4.0.0.201412161056/target/jars/scala-compiler.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/lib/sunrsasign.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_65.jdk/Contents/Home/jre/classes]
not found.

at scala.reflect.internal.MissingRequirementError$.signal(
MissingRequirementError.scala:16)

at scala.reflect.internal.MissingRequirementError$.notFound(
MissingRequirementError.scala:17)

at scala.reflect.internal.Mirrors$RootsBase.getModuleOrClass(
Mirrors.scala:48)

at scala.reflect.internal.Mirrors$RootsBase.getModuleOrClass(
Mirrors.scala:61)

at scala.reflect.internal.Mirrors$RootsBase.staticModuleOrClass(
Mirrors.scala:72)

at scala.reflect.internal.Mirrors$RootsBase.staticClass(Mirrors.scala:119)

at scala.reflect.internal.Mirrors$RootsBase.staticClass(Mirrors.scala:21)

at org.apache.spark.sql.catalyst.ScalaReflection$$typecreator1$1.apply(
ScalaReflection.scala:115)

at scala.reflect.api.TypeTags$WeakTypeTagImpl.tpe$lzycompute(
TypeTags.scala:231)

at scala.reflect.api.TypeTags$WeakTypeTagImpl.tpe(TypeTags.scala:231)

at scala.reflect.api.TypeTags$class.typeOf(TypeTags.scala:335)

at scala.reflect.api.Universe.typeOf(Universe.scala:59)

at org.apache.spark.sql.catalyst.ScalaReflection$class.schemaFor(
ScalaReflection.scala:115)

at org.apache.spark.sql.catalyst.ScalaReflection$.schemaFor(
ScalaReflection.scala:33)

at org.apache.spark.sql.catalyst.ScalaReflection$class.schemaFor(
ScalaReflection.scala:100)

at org.apache.spark.sql.catalyst.ScalaReflection$.schemaFor(
ScalaReflection.scala:33)

at org.apache.spark.sql.catalyst.ScalaReflection$class.attributesFor(
ScalaReflection.scala:94)

at org.apache.spark.sql.catalyst.ScalaReflection$.attributesFor(
ScalaReflection.scala:33)

at org.apache.spark.sql.SQLContext.createSchemaRDD(SQLContext.scala:111)

at com.svairavelu.examples.QueryCSV$.main(QueryCSV.scala:24)

 at com.svairavelu.examples.QueryCSV.main(QueryCSV.scala)