[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.

["鲨鱼辣椒 (Jira)" <ji...@apache.org>]

鲨鱼辣椒 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)