Skip to content

Commit 31e2317

Browse files
author
Davies Liu
committed
Update kafka_wordcount.py
1 parent 370ba61 commit 31e2317

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

examples/src/main/python/streaming/kafka_wordcount.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939

4040
if __name__ == "__main__":
4141
if len(sys.argv) != 3:
42-
print >> sys.stderr, "Usage: network_wordcount.py <zk> <topic>"
42+
print >> sys.stderr, "Usage: kafka_wordcount.py <zk> <topic>"
4343
exit(-1)
4444

4545
sc = SparkContext(appName="PythonStreamingKafkaWordCount")

0 commit comments

Comments
 (0)