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

[Shang Yuanchun (Jira)]

 Kevin Ma created FLINK-20922:
---------------------------------

             Summary: row() function cannot accpet <table alias>.<column> as arguments
                 Key: FLINK-20922
                 URL: https://issues.apache.org/jira/browse/FLINK-20922
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
    Affects Versions: 1.12.0
            Reporter:  Kevin Ma


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*



--
This message was sent by Atlassian Jira
(v8.3.4#803005)