diff options
Diffstat (limited to 'docs')
| -rw-r--r-- | docs/streaming-programming-guide.md | 3 |
1 files changed, 2 insertions, 1 deletions
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 |