[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 <[email protected]> Authored: Mon Oct 17 12:48:35 2016 +0800 Committer: Fabian Hueske <[email protected]> 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()
