[FLINK-20922] row() function cannot accpet <table alias>.<column> as arguments

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.12.0
• Component/s: Table SQL / Planner
• Assignee: Unassigned
• Reporter: Kevin Ma
• Created: 11/Jan/21 07:00
• Updated: 12/Jan/21 10:07
• Resolved: 12/Jan/21 10:07

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

Issue Links

• is duplicated by: FLINK-18027 ROW value constructor cannot deal with complex expressions