[FLINK-31344] Support to update nested columns in update statement

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Table SQL / API
• Labels: pull-request-available stale-assigned
• Assignee: WenJun Min
• Reporter: luoyuxia
• Created: 06/Mar/23 13:19
• Updated: 12/Aug/23 22:35

Description

Currently, it'll throw exception while using update statement to update nested column;

For the following sql:

 

create table (t ROW<`a` INT>) with (xxx);
update t set s.a = 1;

It'll throw the exception:

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 

 

 

Issue Links

• links to: GitHub Pull Request #22378