[hotfix] Remove execute() after print() in Table API examples

This closes apache#735
nltran · Jun 3, 2015 · fad9795 · fad9795
1 parent a750415
commit fad9795
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/flink-staging/flink-table/src/main/java/org/apache/flink/examples/java/JavaTableExample.java b/flink-staging/flink-table/src/main/java/org/apache/flink/examples/java/JavaTableExample.java
@@ -67,6 +67,5 @@ public static void main(String[] args) throws Exception {
  DataSet<WC> result = tableEnv.toSet(filtered, WC.class);
 
  result.print();
- env.execute();
  }
 }
diff --git a/flink-staging/flink-table/src/main/scala/org/apache/flink/examples/scala/PageRankTable.scala b/flink-staging/flink-table/src/main/scala/org/apache/flink/examples/scala/PageRankTable.scala
@@ -129,12 +129,12 @@ object PageRankTable {
  // emit result
  if (fileOutput) {
  result.writeAsCsv(outputPath, "\n", " ")
+ // execute program
+ env.execute("Expression PageRank Example")
  } else {
+ // execute program and print result
  result.print()
  }
-
- // execute program
- env.execute("Expression PageRank Example")
  }
 
  // *************************************************************************