as arguments
[ https://issues.apache.org/jira/browse/FLINK-20922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu closed FLINK-20922.
---------------------------
Resolution: Duplicate
> 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
> Priority: Major
>
> 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)