[ https://issues.apache.org/jira/browse/KAFKA-5850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158405#comment-16158405 ]
Manikumar commented on KAFKA-5850: ---------------------------------- [~saurabhbidwai] This issue is not related to Kafka. You may want to raise the issue on Spark project. > Py4JJavaError: An error occurred while calling o40.loadClass. : > java.lang.ClassNotFoundException: > org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper > --------------------------------------------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-5850 > URL: https://issues.apache.org/jira/browse/KAFKA-5850 > Project: Kafka > Issue Type: Bug > Reporter: Saurabh Bidwai > > --------------------------------------------------------------------------- > Py4JJavaError Traceback (most recent call last) > <ipython-input-10-62bb7226120a> in <module>() > ----> 1 streamer(sc) > <ipython-input-3-99af708ed717> in streamer(sc) > 5 pwords = > load_wordlist("/home/daasuser/twitter/kafkatweets/Twitter-Sentiment-Analysis-Using-Spark-Streaming-And-Kafka/Dataset/positive.txt") > 6 nwords = > load_wordlist("/home/daasuser/twitter/kafkatweets/Twitter-Sentiment-Analysis-Using-Spark-Streaming-And-Kafka/Dataset/negative.txt") > ----> 7 counts = stream(ssc, pwords, nwords, 600) > 8 make_plot(counts) > <ipython-input-9-be266104bdd8> in stream(ssc, pwords, nwords, duration) > 1 def stream(ssc, pwords, nwords, duration): > ----> 2 kstream = KafkaUtils.createDirectStream(ssc, topics = > ['twitterstream'], kafkaParams = {"metadata.broker.list": > ["dn1001:6667","dn2001:6667","dn3001:6667","dn4001:6667"]}) > 3 tweets = kstream.map(lambda x: x[1].encode("utf-8", "ignore")) > 4 > 5 # Each element of tweets will be the text of a tweet. > /usr/hdp/current/spark-client/python/lib/pyspark.zip/pyspark/streaming/kafka.py > in createDirectStream(ssc, topics, kafkaParams, fromOffsets, keyDecoder, > valueDecoder, messageHandler) > 150 if 'ClassNotFoundException' in str(e.java_exception): > 151 KafkaUtils._printErrorMsg(ssc.sparkContext) > --> 152 raise e > 153 > 154 stream = DStream(jstream, ssc, ser).map(func) > Py4JJavaError: An error occurred while calling o40.loadClass. > : java.lang.ClassNotFoundException: > org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:231) > at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:381) > at py4j.Gateway.invoke(Gateway.java:259) > at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:133) > at py4j.commands.CallCommand.execute(CallCommand.java:79) > at py4j.GatewayConnection.run(GatewayConnection.java:209) > at java.lang.Thread.run(Thread.java:745) -- This message was sent by Atlassian JIRA (v6.4.14#64029)