[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972469#comment-15972469
]
ASF GitHub Bot commented on FLINK-6149:
---------------------------------------
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111919363
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/TableEnvironmentTest.scala
---
@@ -335,7 +335,8 @@ class TableEnvironmentTest extends TableTestBase {
val table2 = util.addTable[(Long, Int, String)]('d, 'e, 'f)
- val sqlTable2 = util.tEnv.sql(s"SELECT d, e, f FROM $table2 UNION
SELECT a, b, c FROM $table")
+ val sqlTable2 = util.tEnv.sql(s"SELECT d, e, f FROM $table2 " +
+ s"UNION ALL SELECT a, b, c FROM $table")
--- End diff --
Yes, you are right. DataStream can only do `UNION ALL`.
We should prevent the translation of `UNION` and also change the
explainString to `union all`, IMO.
> add additional flink logical relation nodes
> -------------------------------------------
>
> Key: FLINK-6149
> URL: https://issues.apache.org/jira/browse/FLINK-6149
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Kurt Young
> Assignee: Kurt Young
>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
