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

2016-05-09 Thread Guillermo Ortiz
gt; > > On 9 May 2016 at 13:35, Guillermo Ortiz wrote: > >> 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.deplo

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

2016-05-09 Thread Mich Talebzadeh
or 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.lang.NoClassDefFoundError: kaf

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
rt 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 threw exception: >> java.l

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

2016-05-09 Thread Guillermo Ortiz
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.KafkaCluster.g

java.lang.NoClassDefFoundError: kafka/api/TopicMetadataRequest

2016-05-09 Thread Guillermo Ortiz
.1.jar. * 2016-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/TopicMetadataRequ