You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2016/10/22 08:10:32 UTC
[2/2] flink git commit: [FLINK-4838] [docs] Remove STREAM keyword in
StreamSQLExample
[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 <ow...@gmail.com>
Authored: Mon Oct 17 12:48:35 2016 +0800
Committer: Fabian Hueske <fh...@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()