[hotfix] Removed execute() that followed print() in quickstart wordco…

…unt jobs
nltran · Jun 16, 2015 · d381541 · d381541
1 parent b59c81b
commit d381541
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/...flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/WordCount.java b/...flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/WordCount.java
@@ -63,11 +63,9 @@ public static void main(String[] args) throws Exception {
  .groupBy(0)
  .sum(1);
 
- // emit result
+ // execute and print result
  counts.print();
 
- // execute program
- env.execute("WordCount Example");
  }
 
  //

diff --git a/...nk-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/WordCount.scala b/...nk-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")
  }
 }