You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/06/03 22:32:49 UTC
flink git commit: [hotfix] Remove execute() after print() in Table
API examples
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 <tw...@apache.org>
Authored: Wed May 27 15:32:11 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
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")
}
// *************************************************************************