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
