[
https://issues.apache.org/jira/browse/HUDI-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated HUDI-7265:
-----------------------------
Description:
Since Flink 1.17, Flink SQL support more advanced alter table syntax.
{code:sql}
-- add a new column
ALTER TABLE MyTable ADD category_id STRING COMMENT 'identifier of the category';
-- modify a column type, comment and position
ALTER TABLE MyTable MODIFY measurement double COMMENT 'unit is bytes per
second' AFTER `id`;
-- drop columns
ALTER TABLE MyTable DROP (col1, col2, col3);
-- rename column
ALTER TABLE MyTable RENAME request_body TO payload;
{code}
Find more detail information in [Flink Alter Table SQL
|https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/sql/alter/].
We could support schema evolution by Flink SQL.
> Support schema evolution by Flink SQL using HoodieHiveCatalog
> -------------------------------------------------------------
>
> Key: HUDI-7265
> URL: https://issues.apache.org/jira/browse/HUDI-7265
> Project: Apache Hudi
> Issue Type: Improvement
> Reporter: Jing Zhang
> Priority: Major
>
> Since Flink 1.17, Flink SQL support more advanced alter table syntax.
> {code:sql}
> -- add a new column
> ALTER TABLE MyTable ADD category_id STRING COMMENT 'identifier of the
> category';
> -- modify a column type, comment and position
> ALTER TABLE MyTable MODIFY measurement double COMMENT 'unit is bytes per
> second' AFTER `id`;
> -- drop columns
> ALTER TABLE MyTable DROP (col1, col2, col3);
> -- rename column
> ALTER TABLE MyTable RENAME request_body TO payload;
> {code}
> Find more detail information in [Flink Alter Table SQL
> |https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/sql/alter/].
> We could support schema evolution by Flink SQL.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
