[
https://issues.apache.org/jira/browse/FLINK-39321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
鲨鱼辣椒 updated FLINK-39321:
-------------------------
Summary: Writing data from FlinkCDC to a Paimon dynamic bucket table.
Assigner ID error. (was: 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.)
> Writing data from FlinkCDC to a Paimon dynamic bucket table. Assigner ID
> error.
> -------------------------------------------------------------------------------
>
> Key: FLINK-39321
> URL: https://issues.apache.org/jira/browse/FLINK-39321
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Reporter: 鲨鱼辣椒
> Priority: Major
>
> 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)
