Repository: flink Updated Branches: refs/heads/release-0.9 2359b49f5 -> 0a8142a99
[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/0a8142a9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0a8142a9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0a8142a9 Branch: refs/heads/release-0.9 Commit: 0a8142a9916c6fbe6db4d2a1f0199acd5737d836 Parents: 2359b49 Author: Fabian Hueske <fhue...@apache.org> Authored: Tue Jun 16 22:11:21 2015 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Tue Jun 16 22:13:12 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/0a8142a9/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/0a8142a9/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") } }
