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