xed/worked around by some classloading magic
> at either Spark or application code?
>
>
>
>
>
> *From:* Tathagata Das [mailto:tathagata.das1...@gmail.com]
> *Sent:* Friday, August 29, 2014 7:21 PM
>
> *To:* Anton Brazhnyk
> *Cc:* user@spark.apache.org
> *Subject:* Re
assloading magic at
either Spark or application code?
From: Tathagata Das [mailto:tathagata.das1...@gmail.com]
Sent: Friday, August 29, 2014 7:21 PM
To: Anton Brazhnyk
Cc: user@spark.apache.org
Subject: Re: [Streaming] Akka-based receiver with messages defined in uploaded
jar
Can you try adding the
n.brazh...@genesys.com]
> *Sent:* Wednesday, August 27, 2014 6:46 PM
> *To:* Tathagata Das
> *Cc:* user@spark.apache.org
> *Subject:* RE: [Streaming] Akka-based receiver with messages defined in
> uploaded jar
>
>
>
> Sorry for the delay with answer – was on vacation.
>
Just checked it with 1.0.2
Still same exception.
From: Anton Brazhnyk [mailto:anton.brazh...@genesys.com]
Sent: Wednesday, August 27, 2014 6:46 PM
To: Tathagata Das
Cc: user@spark.apache.org
Subject: RE: [Streaming] Akka-based receiver with messages defined in uploaded
jar
Sorry for the delay
JoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>
> -----Original Message-----
> From: Tathagata Das [mailto:tathagata.das1...@gmail.com]
> Sent: Tuesday, August 05, 2014 5:42 PM
> To: Anton Brazhnyk
>
Can you show us the modified version. The reason could very well be
what you suggest, but I want to understand what conditions lead to
this.
TD
On Tue, Aug 5, 2014 at 3:55 PM, Anton Brazhnyk
wrote:
> Greetings,
>
>
>
> I modified ActorWordCount example a little and it uses simple case class as
Greetings,
I modified ActorWordCount example a little and it uses simple case class as the
message for Streaming instead of the primitive string.
I also modified launch code to not use run-example script, but set spark master
in the code and attach the jar (setJars(...)) with all the classes inc
