You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "suhwan (Jira)" <ji...@apache.org> on 2026/02/09 23:47:00 UTC

[jira] [Created] (FLINK-39055) [iceberg] Support default column values in Iceberg sink connector

suhwan created FLINK-39055:
------------------------------

             Summary: [iceberg] Support default column values in Iceberg sink connector
                 Key: FLINK-39055
                 URL: https://issues.apache.org/jira/browse/FLINK-39055
             Project: Flink
          Issue Type: New Feature
          Components: Flink CDC
            Reporter: suhwan


Summary

In the Iceberg table version 3, Default value support for columns

[https://iceberg.apache.org/spec/#version-3-extended-types-and-capabilities]

 

But now, Iceberg pipeline sink connector does not propagate column default values when creating tables (CreateTableEvent) or adding columns (AddColumnEvent)

 

I think that this can fix Column.getDefaultValueExpression() call in IcebergMetadataApplier or IcebergTypeUtils.

 

 

I refered it

- Paimon sink SchemaChangeProvider: https://github.com/apache/flink-cdc/blob/1c597444886ad3dde268a8adc1f5a0871c768360/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java#L58-L69



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