diff options
| author | baishuo(白硕) <vc_java@hotmail.com> | 2014-04-25 13:18:49 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-04-25 13:18:49 -0700 |
| commit | 8aaef5c75624b48806a05943454f7b72f3ca1bdc (patch) | |
| tree | 9d7583e30f9bff2a09783755deb3136cbad44836 /examples/src | |
| parent | 25a276dd21457fa0db76b6be93765682a50b784a (diff) | |
| download | spark-8aaef5c75624b48806a05943454f7b72f3ca1bdc.tar.gz spark-8aaef5c75624b48806a05943454f7b72f3ca1bdc.tar.bz2 spark-8aaef5c75624b48806a05943454f7b72f3ca1bdc.zip | |
Update KafkaWordCount.scala
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
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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) |