flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [2/2] flink git commit: [FLINK-4838] [docs] Remove STREAM keyword in StreamSQLExample
Date Sat, 22 Oct 2016 08:10:32 GMT
[FLINK-4838] [docs] Remove STREAM keyword in StreamSQLExample

This closes #2645


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/227cdc82
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/227cdc82
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/227cdc82

Branch: refs/heads/master
Commit: 227cdc82917e72ad41180b054f1ca715af394baf
Parents: f0e451a
Author: manuzhang <owenzhang1990@gmail.com>
Authored: Mon Oct 17 12:48:35 2016 +0800
Committer: Fabian Hueske <fhueske@apache.org>
Committed: Sat Oct 22 10:09:56 2016 +0200

----------------------------------------------------------------------
 .../scala/org/apache/flink/examples/scala/StreamSQLExample.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/227cdc82/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala
index 5b39080..63a5413 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala
@@ -59,8 +59,8 @@ object StreamSQLExample {
 
     // union the two tables
     val result = tEnv.sql(
-      "SELECT STREAM * FROM OrderA WHERE amount > 2 UNION ALL " +
-        "SELECT STREAM * FROM OrderB WHERE amount < 2")
+      "SELECT * FROM OrderA WHERE amount > 2 UNION ALL " +
+        "SELECT * FROM OrderB WHERE amount < 2")
 
     result.toDataStream[Order].print()
 


Mime
View raw message