ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Update KafkaWordCount.scala

Browse source 
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
This commit is contained in:
baishuo(白硕) 2014-04-25 13:18:49 -07:00 committed by Tathagata Das
parent 25a276dd21
commit 8aaef5c756
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala
View file

@ -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)