Re: java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

2016-05-09 Thread Guillermo Ortiz
>> org.apache.spark.deploy.yarn.ApplicationMaster - User class threw exception: >> java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest >> java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest >> at >> org.apache.spark.streaming.kafk

Re: java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

2016-05-09 Thread Mich Talebzadeh
looking the log carefully looking for others error. Anyway the complete > Exception is: > > 2016-05-09 13:20:25,646 [Driver] ERROR > org.apache.spark.deploy.yarn.ApplicationMaster - User class threw exception: > java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest > java.lan

Re: java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

2016-05-09 Thread Guillermo Ortiz
I was looking the log carefully looking for others error. Anyway the complete Exception is: 2016-05-09 13:20:25,646 [Driver] ERROR org.apache.spark.deploy.yarn.ApplicationMaster - User class threw exception: java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

Re: java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

2016-05-09 Thread Ted Yu
ght, but I have been >> checking the jar which I import on the SparkUI spark.yarn.secondary.jars >> and they are right and the class exists inside *kafka_2.10-0.8.2.1.jar. * >> >> 2016-05-05 15:51:53,617 [Driver] ERROR >> org.apache.spark.deploy.yarn.ApplicationMaster - User class thr

Re: java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

2016-05-09 Thread Guillermo Ortiz
05 15:51:53,617 [Driver] ERROR > org.apache.spark.deploy.yarn.ApplicationMaster - User class threw exception: > java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest > java.lang.NoClassDefFoundError: *kafka/api/TopicMetadataRequest* > at > org.apache.spark.streaming.kafka.KafkaCluste

java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

2016-05-09 Thread Guillermo Ortiz
-05-05 15:51:53,617 [Driver] ERROR org.apache.spark.deploy.yarn.ApplicationMaster - User class threw exception: java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest java.lang.NoClassDefFoundError: *kafka/api/TopicMetadataRequest