You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Xiang Yang (Jira)" <ji...@apache.org> on 2022/01/17 06:14:00 UTC

[jira] [Updated] (FLINK-25663) SqlParser seems not support using udf in the column of row when writing dml

     [ https://issues.apache.org/jira/browse/FLINK-25663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Xiang Yang updated FLINK-25663:
-------------------------------
    Summary: SqlParser seems not support using udf in the column of row when writing dml  (was: SqlParser seems do not support using udf in the column of row when writing dml)

> SqlParser seems not support using udf in the column of row when writing dml
> ---------------------------------------------------------------------------
>
>                 Key: FLINK-25663
>                 URL: https://issues.apache.org/jira/browse/FLINK-25663
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Planner
>    Affects Versions: 1.13.5
>            Reporter: Xiang Yang
>            Priority: Major
>
> It seems that we cannnot use udf in the column of row when writing dml. For example, we insert data into a hbase table:
> {code:java}
> INSERT INTO user_info 
>   SELECT user_id,
>   ROW(my_udf(user_id)),
>   ROW(update_time)
> FROM pageviews {code}
> then the program will throw error:
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "(" at line 3, column 13.
> Was expecting one of:
>     ")" ...
>     "," ...
>     
>     at org.apache.flink.table.planner.parse.CalciteParser.parse(CalciteParser.java:56)
>     at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:98)
>     at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:724) {code}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)