You can add this jar <http://central.maven.org/maven2/com/101tec/zkclient/0.3/zkclient-0.3.jar> in the classpath to get ride of this. If you are hitting further exceptions like classNotFound for metrics* etc, then make sure you have all these jars in the classpath:
SPARK_CLASSPATH=SPARK_CLASSPATH:/root/akhld/spark/lib/ *spark-streaming-kafka_2.10-1.1.0.jar*:/root/akhld/spark/lib/ *kafka_2.10-0.8.0.jar*:/root/akhld/spark/lib/*zkclient-0.3.jar* :/root/akhld/spark/lib/*metrics-core-2.2.0.jar* Thanks Best Regards On Tue, Oct 21, 2014 at 10:45 AM, skane <sk...@websense.com> wrote: > I'm having the same problem with Spark 1.0.0. I got the " > JavaKafkaWordCount.java" example working on my workstation running Spark > locally after doing a build, but when I tried to get the example running on > YARN, I got the same error. I used the "uber jar" that was created during > the build process for the examples, and I confirmed that > "org/I0Itec/zkclient/serialize/ZkSerializer" is in the uber jar. > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/org-I0Itec-zkclient-serialize-ZkSerializer-ClassNotFound-tp15919p16897.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org > For additional commands, e-mail: user-h...@spark.apache.org > >
