flink git commit: [hotfix] Removed execute() that followed print() in quickstart wordcount jobs

2015-06-16 Thread fhueske 
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 
Authored: Tue Jun 16 22:11:21 2015 +0200
Committer: Fabian Hueske 
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")
   }
 }

flink git commit: [hotfix] Removed execute() that followed print() in quickstart wordcount jobs

2015-06-16 Thread fhueske 
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 
Authored: Tue Jun 16 22:11:21 2015 +0200
Committer: Fabian Hueske 
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")
   }
 }