From 370ba61571b98e9bdfb6636852d4404687143853 Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Mon, 26 Jan 2015 12:25:12 -0800 Subject: [PATCH] Update kafka.py fix spark-submit --- python/pyspark/streaming/kafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/pyspark/streaming/kafka.py b/python/pyspark/streaming/kafka.py index 2e898c06fcf8f..ff1a951b6f11b 100644 --- a/python/pyspark/streaming/kafka.py +++ b/python/pyspark/streaming/kafka.py @@ -74,7 +74,7 @@ def getClassByName(name): # TODO: use --jar once it also work on driver if not e.message or 'call a package' in e.message: print "No kafka package, please put the assembly jar into classpath:" - print " $ bin/submit --driver-class-path external/kafka-assembly/target/" + \ + print " $ bin/spark-submit --driver-class-path external/kafka-assembly/target/" + \ "scala-*/spark-streaming-kafka-assembly-*.jar" raise e ser = PairDeserializer(NoOpSerializer(), NoOpSerializer())