[
https://issues.apache.org/jira/browse/FLINK-25663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiang Yang updated FLINK-25663:
-------------------------------
Component/s: Table SQL / Planner
Affects Version/s: 1.13.5
Description:
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}
Issue Type: Bug (was: Improvement)
Summary: SqlParser seems do not support using udf in the column
of row when writing dml (was: SqlParse)
> SqlParser seems do 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)
