[
https://issues.apache.org/jira/browse/FLINK-35474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849936#comment-17849936
]
stevedengzhi commented on FLINK-35474:
--------------------------------------
First Question: Does the information in the checkpoint record the old table
schema along with the binlog position?:)
> During the process of catching up after a restart, Flink CDC uses the latest
> table information to parse old Mysql binlogs.
> --------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-35474
> URL: https://issues.apache.org/jira/browse/FLINK-35474
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: 1.17.2
> Reporter: stevedengzhi
> Priority: Major
> Attachments: image-2024-05-28-16-13-58-566.png
>
>
> !image-2024-05-28-16-13-58-566.png!
> IN FLINK CDC 2.3.0 VERSION:
> This DDL issue can prevent recovery from checkpoints, leading to infinite
> restarts.
> How to reproduce this issue?（翻译by chatGPT，English not well ）
> Step 1: Turn off Flink CDC.
> Step 2: Perform DDL operations on multiple tables, including deleting
> columns, reducing columns, and adding columns.
> Step 3: Restore Flink CDC from the last checkpoint before it was turned off.
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
