Repository: spark Updated Branches: refs/heads/master 9461f5ee8 -> 22e96b87f
Typo in comment: use 2 seconds instead of 1 Use 2 seconds batch size as duration specified in JavaStreamingContext constructor is 2000 ms Author: Rohan Bhanderi <rohan.bhand...@sjsu.edu> Closes #9714 from RohanBhanderi/patch-2. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/22e96b87 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/22e96b87 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/22e96b87 Branch: refs/heads/master Commit: 22e96b87fb0a0eb4f2f1a8fc29a742ceabff952a Parents: 9461f5e Author: Rohan Bhanderi <rohan.bhand...@sjsu.edu> Authored: Sat Nov 14 13:38:53 2015 +0000 Committer: Sean Owen <so...@cloudera.com> Committed: Sat Nov 14 13:38:53 2015 +0000 ---------------------------------------------------------------------- .../org/apache/spark/examples/streaming/JavaKafkaWordCount.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/22e96b87/examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java index 16ae9a3..337f8ff 100644 --- a/examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java +++ b/examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java @@ -66,7 +66,7 @@ public final class JavaKafkaWordCount { StreamingExamples.setStreamingLogLevels(); SparkConf sparkConf = new SparkConf().setAppName("JavaKafkaWordCount"); - // Create the context with a 1 second batch size + // Create the context with 2 seconds batch size JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, new Duration(2000)); int numThreads = Integer.parseInt(args[3]); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
