[ 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)