flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [hotfix] Remove execute() after print() in Table API examples
Date Wed, 03 Jun 2015 20:32:49 GMT
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 <twalthr@apache.org>
Authored: Wed May 27 15:32:11 2015 +0200
Committer: Stephan Ewen <sewen@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")
   }
 
   // *************************************************************************


Mime
View raw message