[
https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237794#comment-17237794
]
Danny Chen commented on FLINK-20307:
------------------------------------
Hi, [~dwysakowicz] ~ I would like to take this issue ~
> Cannot alias versioned table in a join
> --------------------------------------
>
> Key: FLINK-20307
> URL: https://issues.apache.org/jira/browse/FLINK-20307
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner
> Reporter: Dawid Wysakowicz
> Priority: Critical
> Fix For: 1.12.0
>
>
> A query like:
> {code}
> SELECT p.name, p.qty * r.rate AS price, p.`tstamp` FROM Products p JOIN
> versioned_rates r FOR SYSTEM_TIME AS OF p.`tstamp` ON p.currency = r.currency;
> {code}
> fails with:
> {code}
> [ERROR] Could not execute SQL statement. Reason:
> org.apache.flink.sql.parser.impl.ParseException: Encountered "FOR" at line 1,
> column 108.
> Was expecting one of:
> <EOF>
> "EXCEPT" ...
> "FETCH" ...
> "GROUP" ...
> "HAVING" ...
> "INTERSECT" ...
> "LIMIT" ...
> "OFFSET" ...
> "ON" ...
> "ORDER" ...
> "MINUS" ...
> "TABLESAMPLE" ...
> "UNION" ...
> "USING" ...
> "WHERE" ...
> "WINDOW" ...
> "(" ...
> "NATURAL" ...
> "JOIN" ...
> "INNER" ...
> "LEFT" ...
> "RIGHT" ...
> "FULL" ...
> "CROSS" ...
> "," ...
> "OUTER" ...
> {code}
> When I do not alias the {{versioned_rates}} table everything works as
> expected. Therefore query like just runs:
> {code}
> SELECT p.name, p.qty * versioned_rates.rate AS price, p.`tstamp` FROM
> Products p JOIN versioned_rates FOR SYSTEM_TIME AS OF p.`tstamp` ON
> p.currency = versioned_rates.currency;
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
