flink cdc 获取 mysql ddl 语句

在Flink的CDC任务中，获取MySQL表的DDL语句可以通过以下步骤实现：

1. 在Flink的CDC任务中设置“output-format”参数为“ddl”，并设置“schema-include”参数为“true”：

Properties props = new Properties();
props.setProperty("connector.property-version", "1");

// 设置 CDC 输出格式为 DDL
props.setProperty("format.output-format", "ddl");

// 设置是否包含表结构信息
props.setProperty("schema-include", "true");

2. 启动CDC任务，等待任务启动成功。

3. 获取CDC任务输出的DDL语句。

在获取DDL语句时，需要确保CDC任务已经连接上MySQL数据库，并且MySQL数据库中的二进制日志已经开启。

需要注意的是，Flink的CDC任务只能获取增量数据，因此在获取DDL语句时，需要保证MySQL表的结构没有发生变化。如果MySQL表的结构已经发生变化，需要先停止CDC任务，然后重新启动CDC任务来获取最新的DDL语句。