You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/13 06:28:05 UTC
[jira] [Updated] (FLINK-19670) Query on a view of temporal join throws ParseException
[ https://issues.apache.org/jira/browse/FLINK-19670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yun Gao updated FLINK-19670:
----------------------------
Fix Version/s: 1.16.0
> Query on a view of temporal join throws ParseException
> ------------------------------------------------------
>
> Key: FLINK-19670
> URL: https://issues.apache.org/jira/browse/FLINK-19670
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.11.1
> Reporter: simenliuxing
> Priority: Minor
> Labels: auto-deprioritized-major
> Fix For: 1.15.0, 1.16.0
>
>
> When I run a sql task with flink1.11.1 and blink planner, the following syntax error appears, sql is as follows:
> {code:java}
> CREATE TABLE orders (
> order_id INT,
> product_id INT,
> proctime AS PROCTIME()
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'test',
> 'properties.bootstrap.servers' = 'localhost:9092',
> 'format' = 'json'
> );
> create table products(
> pro_id INT ,
> product_name STRING,
> PRIMARY KEY (pro_id) NOT ENFORCED
> ) WITH (
> 'connector'='jdbc',
> 'url'='jdbc:mysql://localhost:3306/test',
> 'username'='root',
> 'password'='root',
> 'table-name'='result4'
> );
> CREATE TABLE orders_info (
> order_id INT,
> pro_id INT,
> product_name STRING
> ) WITH (
> 'connector' = 'print'
> );
> create view orders_view
> as
> SELECT
> order_id,
> pro_id,
> product_name
> FROM orders
> LEFT JOIN products FOR SYSTEM_TIME AS OF orders.proctime
> ON orders.product_id = products.pro_id;
> INSERT INTO orders_info SELECT * FROM orders_view;
> {code}
> The error is as follows:
> {code:java}
> Caused by: org.apache.flink.sql.parser.impl.ParseException: Encountered "FOR" at line 3, column 73.
> 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" ...
>
> at org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.generateParseException(FlinkSqlParserImpl.java:36086)
> at org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.jj_consume_token(FlinkSqlParserImpl.java:35900)
> at org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlStmtEof(FlinkSqlParserImpl.java:3801)
> at org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.parseSqlStmtEof(FlinkSqlParserImpl.java:248)
> at org.apache.calcite.sql.parser.SqlParser.parseQuery(SqlParser.java:161)
> ... 25 more
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)