flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [2/7] flink git commit: [FLINK-4285] [docs] Update the setup quickstart guide with the new SocketWindowWordCount example
Date Tue, 02 Aug 2016 10:43:54 GMT
[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/7b6ed59a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7b6ed59a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7b6ed59a

Branch: refs/heads/release-1.1
Commit: 7b6ed59a8e9728b392981cc26fbcc3bc9aa29840
Parents: b0a9987
Author: Stephan Ewen <sewen@apache.org>
Authored: Mon Aug 1 11:22:27 2016 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Mon Aug 1 20:07:25 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/7b6ed59a/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/7b6ed59a/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/7b6ed59a/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")


Mime
View raw message