luoyuxia created FLINK-31344:
--------------------------------
Summary: Support to update nested columns in update statement
Key: FLINK-31344
URL: https://issues.apache.org/jira/browse/FLINK-31344
Project: Flink
Issue Type: Improvement
Components: Table SQL / API
Reporter: luoyuxia
Currently, it'll throw exception while using update statement to update nested
column;
For the following sql:
{code:java}
create table (t ROW<`a` INT>) with (xxx);
update t set s.a = 1;{code}
It'll throw the exception:
{code:java}
Caused by: org.apache.flink.sql.parser.impl.ParseException: Encountered "." at
line 1, column 15.
Was expecting:
"=" ...
at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.generateParseException(FlinkSqlParserImpl.java:46382)
at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.jj_consume_token(FlinkSqlParserImpl.java:46190)
at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlUpdate(FlinkSqlParserImpl.java:14389)
at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlStmt(FlinkSqlParserImpl.java:4121)
at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlStmtList(FlinkSqlParserImpl.java:2998)
at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.parseSqlStmtList(FlinkSqlParserImpl.java:306)
at org.apache.calcite.sql.parser.SqlParser.parseStmtList(SqlParser.java:198)
... 33 more {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
