我剛纔複製的火花流wodcount Python代碼,並利用火花提交給運行在星火集羣的單詞計數Python代碼,但它顯示了以下錯誤:火花提交失敗,火花流workdcount Python代碼
py4j.protocol.Py4JJavaError: An error occurred while calling o23.loadClass.
: java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
我確實構建了jar spark-streaming-kafka-assembly_2.10-1.4.0-SNAPSHOT.jar。我使用以下腳本來提交: bin/spark-submit /data/spark-1.3.0-bin-hadoop2.4/wordcount.py --master spark://192.168.100.6:7077 --jars/data /spark-1.3.0-bin-hadoop2.4/kafka-assembly/target/spark-streaming-kafka-assembly_*.jar。
在此先感謝!