Repository: spark Updated Branches: refs/heads/branch-1.1 b4f690d36 -> 24ee61625
Typo error in KafkaWordCount example topicpMap to topicMap Author: Gaspar Munoz <[email protected]> Closes #2614 from gasparms/patch-1 and squashes the following commits: 00aab2c [Gaspar Munoz] Typo error in KafkaWordCount example (cherry picked from commit b81ee0b46d63c2122b88941696654100fd736942) Signed-off-by: Tathagata Das <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/24ee6162 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/24ee6162 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/24ee6162 Branch: refs/heads/branch-1.1 Commit: 24ee61625904c7ec0f717fa665feb0e5266e915e Parents: b4f690d Author: Gaspar Munoz <[email protected]> Authored: Wed Oct 1 13:47:22 2014 -0700 Committer: Tathagata Das <[email protected]> Committed: Wed Oct 1 13:47:36 2014 -0700 ---------------------------------------------------------------------- .../org/apache/spark/examples/streaming/KafkaWordCount.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/24ee6162/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala index 566ba6f..c9e1511 100644 --- a/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala +++ b/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala @@ -53,8 +53,8 @@ object KafkaWordCount { val ssc = new StreamingContext(sparkConf, Seconds(2)) ssc.checkpoint("checkpoint") - val topicpMap = topics.split(",").map((_,numThreads.toInt)).toMap - val lines = KafkaUtils.createStream(ssc, zkQuorum, group, topicpMap).map(_._2) + val topicMap = topics.split(",").map((_,numThreads.toInt)).toMap + val lines = KafkaUtils.createStream(ssc, zkQuorum, group, topicMap).map(_._2) val words = lines.flatMap(_.split(" ")) val wordCounts = words.map(x => (x, 1L)) .reduceByKeyAndWindow(_ + _, _ - _, Minutes(10), Seconds(2), 2) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
