Skip to content

Commit 927acb1

Browse files
Rohan Bhanderisrowen
authored andcommitted
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. (cherry picked from commit 22e96b8) Signed-off-by: Sean Owen <sowen@cloudera.com>
1 parent d5a7ff1 commit 927acb1

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public static void main(String[] args) {
6666

6767
StreamingExamples.setStreamingLogLevels();
6868
SparkConf sparkConf = new SparkConf().setAppName("JavaKafkaWordCount");
69-
// Create the context with a 1 second batch size
69+
// Create the context with 2 seconds batch size
7070
JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, new Duration(2000));
7171

7272
int numThreads = Integer.parseInt(args[3]);

0 commit comments

Comments
 (0)