Re: Problem running JavaDirectKafkaWordCount

2016-03-14 Thread Cody Koeninger
Sounds like the jar you built doesn't include the dependencies (in this case, the spark-streaming-kafka subproject). When you use spark-submit to submit a job to spark, you need to either specify all dependencies as additional --jars arguments (which is a pain), or build an uber-jar containing all

Problem running JavaDirectKafkaWordCount

2016-03-12 Thread Martin Andreoni
Hi, I'm starting with spark and I'm having some issues. When I run the 'jar' example of JavaDirectKafkaWordCount it works perfectly. However, if I compile the code and when I submit it, I'm having the following error: > ERROR ActorSystemImpl: Uncaught fatal error from thread > [sparkDriver-