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-akka.actor.default-dispatcher-2] shutting down ActorSystem 
> [sparkDriver]
> java.lang.NoSuchMethodError: 
> org.apache.spark.streaming.kafka.DirectKafkaInputDStream.id()I

The program is running locally and the driver configuration is with 4g. 

Some help is always welcome, 

Thanks. 
-- 

-------------------------

MARTIN ANDREONI 
 

Reply via email to