From 8aaef5c75624b48806a05943454f7b72f3ca1bdc Mon Sep 17 00:00:00 2001
From: "baishuo(白硕)" <vc_java@hotmail.com>
Date: Fri, 25 Apr 2014 13:18:49 -0700
Subject: Update KafkaWordCount.scala
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

modify the required args number

Author: baishuo(白硕) <vc_java@hotmail.com>

Closes #523 from baishuo/master and squashes the following commits:

0368ba9 [baishuo(白硕)] Update KafkaWordCount.scala
---
 .../main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala b/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala
index 3a18bd02b8..2aa4f1474a 100644
--- a/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala
+++ b/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala
@@ -71,7 +71,7 @@ object KafkaWordCount {
 object KafkaWordCountProducer {
 
   def main(args: Array[String]) {
-    if (args.length < 2) {
+    if (args.length < 4) {
       System.err.println("Usage: KafkaWordCountProducer <metadataBrokerList> <topic> " +
         "<messagesPerSec> <wordsPerMessage>")
       System.exit(1)
-- 
cgit v1.2.3