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
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-