Repository: spark Updated Branches: refs/heads/branch-1.6 d5a7ff11c -> 927acb19b
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 <[email protected]> Closes #9714 from RohanBhanderi/patch-2. (cherry picked from commit 22e96b87fb0a0eb4f2f1a8fc29a742ceabff952a) Signed-off-by: Sean Owen <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/927acb19 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/927acb19 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/927acb19 Branch: refs/heads/branch-1.6 Commit: 927acb19bacf12b6dd7c542057abf1be15f2a359 Parents: d5a7ff1 Author: Rohan Bhanderi <[email protected]> Authored: Sat Nov 14 13:38:53 2015 +0000 Committer: Sean Owen <[email protected]> Committed: Sat Nov 14 13:39:07 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/927acb19/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: [email protected] For additional commands, e-mail: [email protected]
