Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.12.0
-
None
-
None
Description
We have a sql that compose a row with a table’s columns. The simplified sql is like:
INSERT INTO flink_log_sink
SELECT
b.id,
Row(b.app_id, b.message)
FROM flink_log_source a
join flink_log_side b
on a.id = b.id;
When we submit the sql to Flink, the sql cannot be parsed, with the following error message:
org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "." at line 11, column 8.
Was expecting one of:
")" ...
"," ...
at org.apache.flink.table.planner.calcite.CalciteParser.parse(CalciteParser.java:56)
at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:76)
...
ommitted
Attachments
Issue Links
- is duplicated by
-
FLINK-18027 ROW value constructor cannot deal with complex expressions
- Closed