Skip to content

Commit

Permalink
SPARK-1976: fix the misleading part in streaming docs
Browse files Browse the repository at this point in the history
Spark streaming requires at least two working threads, but the document gives the example like

import org.apache.spark.api.java.function._
import org.apache.spark.streaming._
import org.apache.spark.streaming.api._
// Create a StreamingContext with a local master
val ssc = new StreamingContext("local", "NetworkWordCount", Seconds(1))
http://spark.apache.org/docs/latest/streaming-programming-guide.html

Author: CodingCat <zhunansjtu@gmail.com>

Closes apache#924 from CodingCat/master and squashes the following commits:

bb89f20 [CodingCat] update streaming docs
  • Loading branch information
CodingCat authored and conviva-zz committed Sep 4, 2014
1 parent d452793 commit dc1fa46
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion docs/streaming-programming-guide.md
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,8 @@ import org.apache.spark.api.java.function._
import org.apache.spark.streaming._
import org.apache.spark.streaming.api._
// Create a StreamingContext with a local master
val ssc = new StreamingContext("local", "NetworkWordCount", Seconds(1))
// Spark Streaming needs at least two working thread
val ssc = new StreamingContext("local[2]", "NetworkWordCount", Seconds(1))
{% endhighlight %}

Using this context, we then create a new DStream
Expand Down

0 comments on commit dc1fa46

Please sign in to comment.