You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/08/01 17:53:58 UTC
[3/8] flink git commit: [FLINK-4285] [docs] Update the setup
quickstart guide with the new SocketWindowWordCount example
[FLINK-4285] [docs] Update the setup quickstart guide with the new SocketWindowWordCount example
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba12a751
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ba12a751
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ba12a751
Branch: refs/heads/master
Commit: ba12a7514ca7f4548cc9cb166844dd6308138672
Parents: 8847955
Author: Stephan Ewen <se...@apache.org>
Authored: Mon Aug 1 11:22:27 2016 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Aug 1 19:52:12 2016 +0200
----------------------------------------------------------------------
docs/quickstart/setup_quickstart.md | 8 +++-----
.../streaming/examples/socket/SocketWindowWordCount.java | 2 +-
.../scala/examples/socket/SocketWindowWordCount.scala | 2 +-
3 files changed, 5 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ba12a751/docs/quickstart/setup_quickstart.md
----------------------------------------------------------------------
diff --git a/docs/quickstart/setup_quickstart.md b/docs/quickstart/setup_quickstart.md
index 261f14f..2c3e6fd 100644
--- a/docs/quickstart/setup_quickstart.md
+++ b/docs/quickstart/setup_quickstart.md
@@ -56,7 +56,7 @@ Check the __JobManager's web frontend__ at [http://localhost:8081](http://localh
## Run Example
-Now, we are going to run the [SocketTextStreamWordCount example](https://github.com/apache/flink/blob/release-1.0.0/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java) and read text from a socket and count the number of distinct words.
+Now, we are going to run the [SocketWindowWordCount example](https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java) and read text from a socket and count the number of distinct words.
* First of all, we use **netcat** to start local server via
@@ -67,10 +67,8 @@ Now, we are going to run the [SocketTextStreamWordCount example](https://github.
* Submit the Flink program:
~~~bash
- $ bin/flink run examples/streaming/SocketTextStreamWordCount.jar \
- --hostname localhost \
- --port 9000
- Printing result to stdout. Use --output to specify output path.
+ $ bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
+
03/08/2016 17:21:56 Job execution switched to status RUNNING.
03/08/2016 17:21:56 Source: Socket Stream -> Flat Map(1/1) switched to SCHEDULED
03/08/2016 17:21:56 Source: Socket Stream -> Flat Map(1/1) switched to DEPLOYING
http://git-wip-us.apache.org/repos/asf/flink/blob/ba12a751/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java
index 10e8ca0..d6cbe87 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java
@@ -48,7 +48,7 @@ public class SocketWindowWordCount {
final ParameterTool params = ParameterTool.fromArgs(args);
port = params.getInt("port");
} catch (Exception e) {
- System.err.println("No port specified. Please run 'WindowWordCount --port <port>', " +
+ System.err.println("No port specified. Please run 'SocketWindowWordCount --port <port>', " +
"where port is the address of the text server");
System.err.println("To start a simple text server, run 'netcat -l <port>' and type the input text " +
"into the command line");
http://git-wip-us.apache.org/repos/asf/flink/blob/ba12a751/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/socket/SocketWindowWordCount.scala
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/socket/SocketWindowWordCount.scala b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/socket/SocketWindowWordCount.scala
index e942bb5..3b432ec 100644
--- a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/socket/SocketWindowWordCount.scala
+++ b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/socket/SocketWindowWordCount.scala
@@ -43,7 +43,7 @@ object SocketWindowWordCount {
ParameterTool.fromArgs(args).getInt("port")
} catch {
case e: Exception => {
- System.err.println("No port specified. Please run 'WindowWordCount --port <port>', " +
+ System.err.println("No port specified. Please run 'SocketWindowWordCount --port <port>', " +
"where port is the address of the text server")
System.err.println("To start a simple text server, run 'netcat -l <port>' " +
"and type the input text into the command line")