if you are using any other package give it as argument --packages <PACKAGE_NAME>
On Sat, Jan 28, 2017 at 8:14 PM, Jacek Laskowski <ja...@japila.pl> wrote: > 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. >> >> >> >
