[
https://issues.apache.org/jira/browse/FLINK-36509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899629#comment-17899629
]
Ruan Hang commented on FLINK-36509:
-----------------------------------
3.2 : 40db6d5eb7661696797acba30384e37e56cdac5a
> Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink.
> ----------------------------------------------------------------------------
>
> Key: FLINK-36509
> URL: https://issues.apache.org/jira/browse/FLINK-36509
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Affects Versions: cdc-3.2.0
> Reporter: Yanquan Lv
> Assignee: Yanquan Lv
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.3.0, cdc-3.2.1
>
>
> When using Paimon as pipeline sink, If a field is added to the partition
> field but not to the primary key field in transform, we will met Unsupported
> bucket mode: GLOBAL_DYNAMIC error in Paimon sink.
> How to reproduct:
>
> {code:java}
> source:
> type: mysql
> name: MySQL Source
> hostname: 127.0.0.1
> port: 3306
> username: admin
> password: pass
> tables: bdb.user_table
> server-id: 5401-5404
> transform:
> - source-table: bdb.user_table
> partition-keys: product_name
> sink:
> type: paimon
> name: Paimon Sink
> catalog.properties.metastore: filesystem
> catalog.properties.warehouse: /path/warehouse
> pipeline:
> name: MySQL to Paimon Pipeline
> parallelism: 2{code}
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
