flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject flink git commit: [hotfix] Removed execute() that followed print() in quickstart wordcount jobs
Date Tue, 16 Jun 2015 20:13:33 GMT
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 <fhueske@apache.org>
Authored: Tue Jun 16 22:11:21 2015 +0200
Committer: Fabian Hueske <fhueske@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")
   }
 }


Mime
View raw message