LvYanquan created FLINK-36509:
---------------------------------
Summary: 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: LvYanquan
Fix For: cdc-3.2.0
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)
