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 JAR
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
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
...@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.
As I said I was using modified version of launcher from
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
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
anton.brazh...@genesys.com wrote:
Greetings,
I modified ActorWordCount example a little and it uses