[jira] [Created] (FLINK-39321) When writing to Paimon via FlinkCDC , if 'dynamic-bucket.initial-buckets' = '1' is set and the job parallelism is greater than 1, an error will be reported: This is a bug, record assign id %s should equal to assign id %s.

Tue, 24 Mar 2026 20:13:04 -0700 

鲨鱼辣椒 created FLINK-39321:
----------------------------

             Summary: When writing to Paimon via FlinkCDC , if 
'dynamic-bucket.initial-buckets' = '1' is set and the job parallelism is 
greater than 1, an error will be reported: This is a bug, record assign id %s 
should equal to assign id %s.
                 Key: FLINK-39321
                 URL: https://issues.apache.org/jira/browse/FLINK-39321
             Project: Flink
          Issue Type: Bug
          Components: Flink CDC
            Reporter: 鲨鱼辣椒


When using Flink CDC 3.5.0 to write to a Paimon dynamic bucket table with 
dynamic-bucket.initial-buckets=1 and Flink parallelism > 1, the following 
exception is thrown:

java.lang.IllegalArgumentException: This is a bug, record assign id ? should 
equal to assign id ?.



 
I have attempted to fix this bug, and by comparison, the latest version appears 
to still have this bug.
 



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

Reply via email to