[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/a1926799 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a1926799 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a1926799 Branch: refs/heads/release-1.1 Commit: a1926799d30aae33ca14580fcd494286797e1297 Parents: 49e66be Author: Stephan Ewen <se...@apache.org> Authored: Mon Aug 1 11:22:27 2016 +0200 Committer: Ufuk Celebi <u...@apache.org> Committed: Tue Aug 2 20:24:36 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/a1926799/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/a1926799/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/a1926799/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")
