You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by td...@apache.org on 2014/07/04 03:31:24 UTC
git commit: Streaming programming guide typos
Repository: spark
Updated Branches:
refs/heads/master d4c30cd99 -> fdc4c112e
Streaming programming guide typos
Fix a bad Java code sample and a broken link in the streaming programming guide.
Author: Clément MATHIEU <cl...@unportant.info>
Closes #1286 from cykl/streaming-programming-guide-typos and squashes the following commits:
b0908cb [Clément MATHIEU] Fix broken URL
9d3c535 [Clément MATHIEU] Spark streaming requires at least two working threads (scala version was OK)
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fdc4c112
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fdc4c112
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fdc4c112
Branch: refs/heads/master
Commit: fdc4c112e7c2ac585d108d03209a642aa8bab7c8
Parents: d4c30cd
Author: Clément MATHIEU <cl...@unportant.info>
Authored: Thu Jul 3 18:31:18 2014 -0700
Committer: Tathagata Das <ta...@gmail.com>
Committed: Thu Jul 3 18:31:18 2014 -0700
----------------------------------------------------------------------
docs/streaming-programming-guide.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/fdc4c112/docs/streaming-programming-guide.md
----------------------------------------------------------------------
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md
index ce8e58d..90a0eef 100644
--- a/docs/streaming-programming-guide.md
+++ b/docs/streaming-programming-guide.md
@@ -148,7 +148,7 @@ import org.apache.spark.streaming.*;
import org.apache.spark.streaming.api.java.*;
import scala.Tuple2;
// Create a StreamingContext with a local master
-JavaStreamingContext jssc = new JavaStreamingContext("local", "JavaNetworkWordCount", new Duration(1000))
+JavaStreamingContext jssc = new JavaStreamingContext("local[2]", "JavaNetworkWordCount", new Duration(1000))
{% endhighlight %}
Using this context, we then create a new DStream
@@ -216,7 +216,7 @@ jssc.awaitTermination(); // Wait for the computation to terminate
{% endhighlight %}
The complete code can be found in the Spark Streaming example
-[JavaNetworkWordCount]({{site.SPARK_GITHUB_URL}}/blob/master/examples/src/main/java/index.html?org/apache/spark/examples/streaming/JavaNetworkWordCount.java).
+[JavaNetworkWordCount]({{site.SPARK_GITHUB_URL}}/blob/master/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java).
<br>
</div>