Repository: spark Updated Branches: refs/heads/branch-1.0 97bfeda9f -> a0912a802
Update KafkaWordCount.scala modify the required args number Author: baishuo(ç½ç¡) <vc_j...@hotmail.com> Closes #523 from baishuo/master and squashes the following commits: 0368ba9 [baishuo(ç½ç¡)] Update KafkaWordCount.scala (cherry picked from commit 8aaef5c75624b48806a05943454f7b72f3ca1bdc) Signed-off-by: Tathagata Das <tathagata.das1...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/a0912a80 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/a0912a80 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/a0912a80 Branch: refs/heads/branch-1.0 Commit: a0912a802c1c620e4e6de31bd8228e9aebc4c57f Parents: 97bfeda Author: baishuo(ç½ç¡) <vc_j...@hotmail.com> Authored: Fri Apr 25 13:18:49 2014 -0700 Committer: Tathagata Das <tathagata.das1...@gmail.com> Committed: Fri Apr 25 13:20:16 2014 -0700 ---------------------------------------------------------------------- .../scala/org/apache/spark/streaming/examples/KafkaWordCount.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/a0912a80/examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala ---------------------------------------------------------------------- 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 3a18bd0..2aa4f14 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)
