You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Muhammad (Jira)" <ji...@apache.org> on 2025/08/28 10:21:00 UTC

[jira] [Created] (FLINK-38292) Flink CDC doesn't support altering table properties for Paimon Sinks

Muhammad created FLINK-38292:
--------------------------------

             Summary: 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


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)