[
https://issues.apache.org/jira/browse/FLINK-38808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38808:
-----------------------------------
Labels: Flink-CDC iceberg pull-request-available (was: Flink-CDC iceberg)
> Support partition transforms in Iceberg sink
> --------------------------------------------
>
> Key: FLINK-38808
> URL: https://issues.apache.org/jira/browse/FLINK-38808
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Affects Versions: 3.0.0
> Reporter: ChaoFang
> Priority: Major
> Labels: Flink-CDC, iceberg, pull-request-available
> Fix For: 3.0.0
>
>
> support for Iceberg partition transforms in the Iceberg sink. Previously,
> only identity partitioning was supported. With this change, users can utilize
> standard Iceberg transforms like `year`, `month`, `day`, `hour`, `bucket`,
> and `truncate` when defining partition keys.
>
> **Example:**
>
> sink.partition-key =
> "testdb.table1:year(create_time);testdb.table2:bucket[16](id)"
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
