From 3faa084fffdae559839af13a6c0e4c39ac81338f Mon Sep 17 00:00:00 2001 From: CodingCat Date: Fri, 30 May 2014 22:06:08 -0700 Subject: SPARK-1976: fix the misleading part in streaming docs 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 Closes #924 from CodingCat/master and squashes the following commits: bb89f20 [CodingCat] update streaming docs (cherry picked from commit 41bfdda3cc53b44b0fb2105533b7c0e1a69eb3bb) Signed-off-by: Reynold Xin --- docs/streaming-programming-guide.md | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'docs') diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index b95f818d0f..bbee67f54c 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -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 -- cgit v1.2.3