RE: [Streaming] Akka-based receiver with messages defined in uploaded jar

2014-09-02 Thread Anton Brazhnyk
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

Re: [Streaming] Akka-based receiver with messages defined in uploaded jar

2014-09-02 Thread Tathagata Das
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

RE: [Streaming] Akka-based receiver with messages defined in uploaded jar

2014-08-29 Thread Anton Brazhnyk
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

Re: [Streaming] Akka-based receiver with messages defined in uploaded jar

2014-08-29 Thread Tathagata Das
...@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

[Streaming] Akka-based receiver with messages defined in uploaded jar

2014-08-05 Thread Anton Brazhnyk
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

Re: [Streaming] Akka-based receiver with messages defined in uploaded jar

2014-08-05 Thread Tathagata Das
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