[ 
https://issues.apache.org/jira/browse/FLINK-38292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Muhammad updated FLINK-38292:
-----------------------------
    Labels: paimon  (was: )

> Flink CDC doesn't support altering table properties for Paimon Sinks
> --------------------------------------------------------------------
>
>                 Key: FLINK-38292
>                 URL: https://issues.apache.org/jira/browse/FLINK-38292
>             Project: Flink
>          Issue Type: New Feature
>          Components: Flink CDC
>            Reporter: Muhammad
>            Priority: Minor
>              Labels: paimon
>
> While working with Flink CDC with Paimon Sink, it was observed that table 
> options are only used at [the time of table 
> creation|https://github.com/apache/flink-cdc/blob/master/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java#L195].
>  This means if any of the table options need to be changed after the creation 
> of Paimon table, it has to be applied separately via Flink SQL.
> As there are immutable table options that cannot be changed once the table is 
> created like primary key definitions, partitioning keys and buckets. This 
> ticket is only for allowing updating the mutable table properties like 
> compaction settings, snapshot retention etc. This will allow making all the 
> table option changes via the FlinkCDC sink configurations.



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

Reply via email to