ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Typo in comment: use 2 seconds instead of 1

Browse source 
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.
This commit is contained in:
Rohan Bhanderi 2015-11-14 13:38:53 +00:00 committed by Sean Owen
parent 9461f5ee80
commit 22e96b87fb
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java
View file

@ -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]);