aboutsummaryrefslogtreecommitdiff
path: root/examples/src/main/python/streaming/kafka_wordcount.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/src/main/python/streaming/kafka_wordcount.py')
-rw-r--r--examples/src/main/python/streaming/kafka_wordcount.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/python/streaming/kafka_wordcount.py b/examples/src/main/python/streaming/kafka_wordcount.py
index ed398a82b8..f82f161cb8 100644
--- a/examples/src/main/python/streaming/kafka_wordcount.py
+++ b/examples/src/main/python/streaming/kafka_wordcount.py
@@ -23,7 +23,7 @@
http://kafka.apache.org/documentation.html#quickstart
and then run the example
- `$ bin/spark-submit --driver-class-path external/kafka-assembly/target/scala-*/\
+ `$ bin/spark-submit --jars external/kafka-assembly/target/scala-*/\
spark-streaming-kafka-assembly-*.jar examples/src/main/python/streaming/kafka_wordcount.py \
localhost:2181 test`
"""