[
https://issues.apache.org/jira/browse/FLINK-37388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930912#comment-17930912
]
zexin gong commented on FLINK-37388:
------------------------------------
I think MySqlPipelineRecordEmitter should not send CreateTableEvent after
recovery because the downstream (PreTransformOperator) has already persisted
the TableSchema using OperatorStateStore#getUnionListState.
I am willing to submit a PR for this, please assign the issue to me.
> [BUG] Field names must be unique.
> ---------------------------------
>
> Key: FLINK-37388
> URL: https://issues.apache.org/jira/browse/FLINK-37388
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: 3.0.0
> Reporter: zexin gong
> Priority: Major
> Attachments: screenshot-20250226-171451.png
>
>
> If configured of schema.change.behavior: EVOLVE, an exception may be
> triggered when reading binlog split: Field names must be unique. Found
> duplicates: [xxx]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
