FlinkCDC 报错 'io.debezium.text.ParsingException: DDL statement couldn't be parsed.' 解决方法

FlinkCDC 在解析 DDL 语句时出现错误 'io.debezium.text.ParsingException: DDL statement couldn't be parsed.'，通常是由于 DDL 语句格式不兼容导致的。您可以尝试以下两种解决方案：

1. 升级 FlinkCDC 版本：升级到最新版本，新版本可能已经修复了相关问题。

2. 修改 MySQL 配置文件：如果无法升级 FlinkCDC 版本，可以在 MySQL 配置文件中添加以下配置：

   binlog_format=row
   

   该配置将强制 MySQL 使用 'row' 格式记录 binlog，提高 DDL 语句解析兼容性。修改后重启 MySQL 服务，并重新执行 FlinkCDC 任务。