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)