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)