spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From angel2014 <angel.alvarez.pas...@gmail.com>
Subject Re: ClassNotFoundException in standalone mode
Date Fri, 21 Nov 2014 03:16:28 GMT
Can you make sure the class "SimpleApp$$anonfun$1" is included in your app
jar?

2014-11-20 18:19 GMT+01:00 Benoit Pasquereau [via Apache Spark User List] <
ml-node+s1001560n19391h11@n3.nabble.com>:

>  Hi Guys,
>
>
>
> I’m having an issue in standalone mode (Spark 1.1, Hadoop 2.4, Windows
> Server 2008).
>
>
>
> A very simple program runs fine in local mode but fails in standalone
> mode.
>
>
>
> Here is the error:
>
>
>
> 14/11/20 17:01:53 INFO DAGScheduler: Failed to run count at
> SimpleApp.scala:22
>
> Exception in thread "main" org.apache.spark.SparkException: Job aborted
> due to stage failure: Task 0 in stage 0.0 failed 4 times, most recent
> failure: Lost task
>
> 0.3 in stage 0.0 (TID 6, UK-RND-PN02.actixhost.eu):
> java.lang.ClassNotFoundException: SimpleApp$$anonfun$1
>
>         java.net.URLClassLoader$1.run(URLClassLoader.java:202)
>
>
>
> I have added the jar to the SparkConf() to be on the safe side and it
> appears in standard output (copied after the code):
>
>
>
> /* SimpleApp.scala */
>
> import org.apache.spark.SparkContext
>
> import org.apache.spark.SparkContext._
>
> import org.apache.spark.SparkConf
>
>
>
> import java.net.URLClassLoader
>
>
>
> object SimpleApp {
>
>   def main(args: Array[String]) {
>
>     val logFile = "S:\\spark-1.1.0-bin-hadoop2.4\\README.md"
>
>     val conf = new
> SparkConf()//.setJars(Seq("s:\\spark\\simple\\target\\scala-2.10\\simple-project_2.10-1.0.jar"))
>
>      .setMaster("spark://UK-RND-PN02.actixhost.eu:7077")
>
>      //.setMaster("local[4]")
>
>      .setAppName("Simple Application")
>
>     val sc = new SparkContext(conf)
>
>
>
>     val cl = ClassLoader.getSystemClassLoader
>
>     val urls = cl.asInstanceOf[URLClassLoader].getURLs
>
>     urls.foreach(url => println("Executor classpath is:" + url.getFile))
>
>
>
>     val logData = sc.textFile(logFile, 2).cache()
>
>     val numAs = logData.filter(line => line.contains("a")).count()
>
>     val numBs = logData.filter(line => line.contains("b")).count()
>
>     println("Lines with a: %s, Lines with b: %s".format(numAs, numBs))
>
>     sc.stop()
>
>   }
>
> }
>
>
>
> Simple-project is in the executor classpath list:
>
> 14/11/20 17:01:48 INFO SparkDeploySchedulerBackend: SchedulerBackend is
> ready for scheduling beginning after reached minRegisteredResourcesRatio:
> 0.0
>
> Executor classpath is:/S:/spark/simple/
>
> Executor classpath is:
> */S:/spark/simple/target/scala-2.10/simple-project_2.10-1.0.jar*
>
> Executor classpath is:/S:/spark-1.1.0-bin-hadoop2.4/conf/
>
> Executor classpath
> is:/S:/spark-1.1.0-bin-hadoop2.4/lib/spark-assembly-1.1.0-hadoop2.4.0.jar
>
> Executor classpath is:/S:/spark/simple/
>
> Executor classpath
> is:/S:/spark-1.1.0-bin-hadoop2.4/lib/datanucleus-api-jdo-3.2.1.jar
>
> Executor classpath
> is:/S:/spark-1.1.0-bin-hadoop2.4/lib/datanucleus-core-3.2.2.jar
>
> Executor classpath
> is:/S:/spark-1.1.0-bin-hadoop2.4/lib/datanucleus-rdbms-3.2.1.jar
>
> Executor classpath is:/S:/spark/simple/
>
>
>
> Would you have any idea how I could investigate further ?
>
>
>
> Thanks !
>
> Benoit.
>
>
>
>
>
> PS: I could attach a debugger to the Worker where the
> ClassNotFoundException happens but it is a bit painful
>  This message and the information contained herein is proprietary and
> confidential and subject to the Amdocs policy statement, you may review at
> http://www.amdocs.com/email_disclaimer.asp
>
> ------------------------------
>  If you reply to this email, your message will be added to the discussion
> below:
>
> http://apache-spark-user-list.1001560.n3.nabble.com/ClassNotFoundException-in-standalone-mode-tp19391.html
>  To start a new topic under Apache Spark User List, email
> ml-node+s1001560n1h21@n3.nabble.com
> To unsubscribe from Apache Spark User List, click here
> <http://apache-spark-user-list.1001560.n3.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=1&code=YW5nZWwuYWx2YXJlei5wYXNjdWFAZ21haWwuY29tfDF8ODAzOTc5ODky>
> .
> NAML
> <http://apache-spark-user-list.1001560.n3.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml>
>




--
View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/ClassNotFoundException-in-standalone-mode-tp19391p19443.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
Mime
View raw message