Repository: flink Updated Branches: refs/heads/master a750415b6 -> fad979532
[hotfix] Remove execute() after print() in Table API examples This closes #735 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fad97953 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fad97953 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fad97953 Branch: refs/heads/master Commit: fad979532e8e31f36c390303be432cb969d7f3e7 Parents: a750415 Author: twalthr <[email protected]> Authored: Wed May 27 15:32:11 2015 +0200 Committer: Stephan Ewen <[email protected]> Committed: Wed Jun 3 22:31:30 2015 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/examples/java/JavaTableExample.java | 1 - .../scala/org/apache/flink/examples/scala/PageRankTable.scala | 6 +++--- 2 files changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/fad97953/flink-staging/flink-table/src/main/java/org/apache/flink/examples/java/JavaTableExample.java ---------------------------------------------------------------------- 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 index c29fc67..e898b5d 100644 --- 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 class JavaTableExample { DataSet<WC> result = tableEnv.toSet(filtered, WC.class); result.print(); - env.execute(); } } http://git-wip-us.apache.org/repos/asf/flink/blob/fad97953/flink-staging/flink-table/src/main/scala/org/apache/flink/examples/scala/PageRankTable.scala ---------------------------------------------------------------------- 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 index c0e0f6c..d944bab 100644 --- 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") } // *************************************************************************
