diff options
| author | Rohan Bhanderi <rohan.bhanderi@sjsu.edu> | 2015-11-14 13:38:53 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-11-14 13:38:53 +0000 |
| commit | 22e96b87fb0a0eb4f2f1a8fc29a742ceabff952a (patch) | |
| tree | c5572e75c6fcc4576bd04a2501fb08805892d949 /examples | |
| parent | 9461f5ee80e51fd709d6f573c333936cb3c2acc5 (diff) | |
| download | spark-22e96b87fb0a0eb4f2f1a8fc29a742ceabff952a.tar.gz spark-22e96b87fb0a0eb4f2f1a8fc29a742ceabff952a.tar.bz2 spark-22e96b87fb0a0eb4f2f1a8fc29a742ceabff952a.zip | |
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.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java | 2 |
1 files changed, 1 insertions, 1 deletions
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 16ae9a3319..337f8ffb5b 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]); |