You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2015/06/16 22:12:35 UTC
flink git commit: [hotfix] Removed execute() that followed print() in
quickstart wordcount jobs
Repository: flink
Updated Branches:
refs/heads/master b59c81bc4 -> d38154129
[hotfix] Removed execute() that followed print() in quickstart wordcount jobs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3815412
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d3815412
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d3815412
Branch: refs/heads/master
Commit: d38154129b8298d998b955e6450a05b79f7cd995
Parents: b59c81b
Author: Fabian Hueske <fh...@apache.org>
Authored: Tue Jun 16 22:11:21 2015 +0200
Committer: Fabian Hueske <fh...@apache.org>
Committed: Tue Jun 16 22:11:21 2015 +0200
----------------------------------------------------------------------
.../resources/archetype-resources/src/main/java/WordCount.java | 4 +---
.../resources/archetype-resources/src/main/scala/WordCount.scala | 4 +---
2 files changed, 2 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d3815412/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/WordCount.java
----------------------------------------------------------------------
diff --git a/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/WordCount.java b/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/WordCount.java
index f250996..6202238 100644
--- a/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/WordCount.java
+++ b/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/WordCount.java
@@ -63,11 +63,9 @@ public class WordCount {
.groupBy(0)
.sum(1);
- // emit result
+ // execute and print result
counts.print();
- // execute program
- env.execute("WordCount Example");
}
//
http://git-wip-us.apache.org/repos/asf/flink/blob/d3815412/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/WordCount.scala
----------------------------------------------------------------------
diff --git a/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/WordCount.scala b/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/WordCount.scala
index 150830f..b88dcc6 100644
--- a/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/WordCount.scala
+++ b/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/WordCount.scala
@@ -46,10 +46,8 @@ object WordCount {
.groupBy(0)
.sum(1)
- // emit result
+ // execute and print result
counts.print()
- // execute program
- env.execute("WordCount Example")
}
}