大佬们，Flink cdc 抽MySQL，回滚到之前的checkpoint的时候，之前的tablel

1. 问题描述： 用户在使用Flink CDC从MySQL抽取数据时，遇到了一个关于Checkpoint回滚后tablelist（表白名单）配置是否仍然生效的问题。具体而言，用户想知道当作业因故回滚到之前的Checkpoint时，最初配置的tablelist（用于过滤需要读取的表）是否还能正常工作，即是否会按照原配置的表列表进行数据读取。

2. 背景信息：

   • Checkpoint机制：Flink通过Checkpoint机制实现容错，当作业失败或手动重启时，可以从最近成功的Checkpoint状态恢复执行，确保数据处理的精确一次语义。
   • Flink CDC for MySQL：Flink CDC连接器允许用户从MySQL数据库中抽取数据，支持全量和增量抽取模式，并且可以通过配置tableList参数来指定需要同步的表。

3. 解决方案：

   • 当Flink作业因为异常或其他原因回滚到之前保存的Checkpoint时，它会尝试从Checkpoint记录的状态继续执行。这意味着包括source配置（如tableList）在内的所有作业配置都会被恢复到Checkpoint时的状态。
   • 因此，如果在作业启动时设置了tableList以过滤特定表，那么即使作业回滚，这个配置依然有效。Flink会基于Checkpoint中的元数据信息，继续只读取那些在tableList中指定的表的数据。

4. 注意事项：

   • 确保在定义Flink作业时正确设置了tableList参数，格式应包含数据库名和表名，例如yourDatabaseName.yourTableName。
   • 如果在作业运行期间修改了tableList配置并期望新配置在回滚后生效，这是不可能的，因为Checkpoint会保存作业当时的配置状态。

5. 示例代码： 在DataStream API中配置MySQL CDC Source时，确保tableList正确设置，例如：

   env.addSource(
      new MySQLCDCSource<>(...),
      "MySQLSource")
     .setParallelism(1)
     .configure(
         MySQLSourceConfigBuilder.builder()
             .hostname("localhost")
             .port(3306)
             .databaseList("yourDatabase") // 数据库名
             .tableList("yourDatabase.yourTable1,yourDatabase.yourTable2") // 表白名单
             ...
             .build());
   

总结来说，Flink CDC在从MySQL抽取数据时，即便作业回滚到之前的Checkpoint，之前配置的tablelist依旧会生效，确保数据抽取范围不变。