spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sro...@apache.org
Subject spark git commit: Typo in comment: use 2 seconds instead of 1
Date Sat, 14 Nov 2015 13:39:03 GMT
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.bhanderi@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.bhanderi@sjsu.edu>
Authored: Sat Nov 14 13:38:53 2015 +0000
Committer: Sean Owen <sowen@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message