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)
