Hi, How did you start spark-shell?
Jacek On 28 Jan 2017 11:20 a.m., "Mich Talebzadeh" <mich.talebza...@gmail.com> wrote: > > Hi, > > My spark-streaming application works fine when compiled with Maven with > uber jar file. > > With spark-shell this program throws an error as follows: > > scala> val dstream = KafkaUtils.createDirectStream[String, String, > StringDecoder, StringDecoder](streamingContext, kafkaParams, topics) > java.lang.NoClassDefFoundError: Could not initialize class kafka.consumer. > FetchRequestAndResponseStatsRegistry$ > > FYI KafkaUtils itself exists > > scala> KafkaUtils > res22: org.apache.spark.streaming.kafka.KafkaUtils.type = > org.apache.spark.streaming.kafka.KafkaUtils$@3ae931b6 > > > I guess I am missing a jar file or something? > > thanks > > Dr Mich Talebzadeh > > > > LinkedIn * > https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw > <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>* > > > > http://talebzadehmich.wordpress.com > > > *Disclaimer:* Use it at your own risk. Any and all responsibility for any > loss, damage or destruction of data or any other property which may arise > from relying on this email's technical content is explicitly disclaimed. > The author will in no case be liable for any monetary damages arising from > such loss, damage or destruction. > > >
