From 31e2317a31c90b23a7b085c7fd5a1de8998194a6 Mon Sep 17 00:00:00 2001
From: Davies Liu <davies@databricks.com>
Date: Tue, 27 Jan 2015 11:21:11 -0800
Subject: [PATCH] Update kafka_wordcount.py

---
 examples/src/main/python/streaming/kafka_wordcount.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/examples/src/main/python/streaming/kafka_wordcount.py b/examples/src/main/python/streaming/kafka_wordcount.py
index dad760aa4db54..7a023ee410735 100644
--- a/examples/src/main/python/streaming/kafka_wordcount.py
+++ b/examples/src/main/python/streaming/kafka_wordcount.py
@@ -39,7 +39,7 @@
 
 if __name__ == "__main__":
     if len(sys.argv) != 3:
-        print >> sys.stderr, "Usage: network_wordcount.py <zk> <topic>"
+        print >> sys.stderr, "Usage: kafka_wordcount.py <zk> <topic>"
         exit(-1)
 
     sc = SparkContext(appName="PythonStreamingKafkaWordCount")