[ 
https://issues.apache.org/jira/browse/FLINK-40146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18096152#comment-18096152
 ] 

Mao Jiayi edited comment on FLINK-40146 at 7/14/26 11:18 AM:
-------------------------------------------------------------

I would like to try supporting this. 


was (Author: JIRAUSER313423):
I would like to try supporting this improvement. 

> Support AlterTableCommentEvent in StarRocks sink
> ------------------------------------------------
>
>                 Key: FLINK-40146
>                 URL: https://issues.apache.org/jira/browse/FLINK-40146
>             Project: Flink
>          Issue Type: Improvement
>          Components: Flink CDC
>            Reporter: Mao Jiayi
>            Priority: Major
>
> Noticed that FLINK-37203 (https://issues.apache.org/jira/browse/FLINK-37203) 
> introduced AlterTableCommentEvent and AlterColumnCommentEvent to support 
> synchronizing table/column comment changes in Flink CDC. The corresponding PR 
> (https://github.com/apache/flink-cdc/pull/3893) implemented this capability 
> for several sinks, but the StarRocks sink was left unsupported with a TODO 
> and warning in StarRocksMetadataApplier.
> When an upstream table comment is changed, the StarRocks pipeline sink 
> currently does not propagate the table comment change to the downstream 
> StarRocks table. This means the table comment in StarRocks may become 
> inconsistent with the upstream table after schema evolution.
> StarRocks supports altering table comments since version 3.1 with syntax like 
> ALTER TABLE [db.]tbl COMMENT = "new table comment". Therefore, the StarRocks 
> pipeline sink should support AlterTableCommentEvent when the downstream 
> StarRocks version is 3.1 or later.
> For StarRocks versions lower than 3.1, the sink should reject the unsupported 
> schema change clearly, for example by throwing 
> UnsupportedSchemaChangeEventException, instead of silently skipping it. This 
> allows TRY_EVOLVE mode to tolerate the unsupported change while EVOLVE mode 
> fails with a clear error.
> The implementation should also properly escape the table comment string when 
> building the ALTER TABLE statement.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to