We're running Kafka 0.8.2.2 Is that the problem, why? -----Oorspronkelijk bericht----- Van: Sean Owen [mailto:so...@cloudera.com] Verzonden: woensdag 4 mei 2016 10:41 Aan: Michel Hubert <mich...@phact.nl> CC: user@spark.apache.org Onderwerp: Re: run-example streaming.KafkaWordCount fails on CDH 5.7.0
Please try the CDH forums; this is the Spark list: http://community.cloudera.com/t5/Advanced-Analytics-Apache-Spark/bd-p/Spark Before you even do that, I can tell you to double check you're running Kafka 0.9. On Wed, May 4, 2016 at 9:29 AM, Michel Hubert <mich...@phact.nl> wrote: > > > Hi, > > > > After an upgrade to CDH 5.7.0 we have troubles with the Kafka to Spark > Streaming. > > > > The example jar doesn’t work: > > > > /opt/cloudera/parcels/CDH/lib/spark/bin/run-example > streaming.KafkaWordCount …. > > > > Attached is a log file. > > > > 16/05/04 10:06:23 WARN consumer.ConsumerFetcherThread: > [ConsumerFetcherThread-wordcount1_host81436-cld.domain.com-14623491821 > 72-13b9f2e7-0-2], Error in fetch > kafka.consumer.ConsumerFetcherThread$FetchRequest@47fb7e6d. > Possible cause: java.nio.BufferUnderflowException > > 16/05/04 10:06:24 WARN consumer.ConsumerFetcherThread: > [ConsumerFetcherThread-wordcount1_host81436-cld.domain.com-14623491821 > 72-13b9f2e7-0-1], Error in fetch > kafka.consumer.ConsumerFetcherThread$FetchRequest@73b9a762. > Possible cause: java.lang.IllegalArgumentException > > > > We have no problem running this from my development pc, only in > product op CDH 5.7.0 environment. > > > > > > Any ideas? > > > > Thanks, > > Michel > > > > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For > additional commands, e-mail: user-h...@spark.apache.org
