mysql to doris. flink-cdc 怎么重新启动时 续传，而不是从 0 开始

[qbmiller]

bash bin/flink-cdc.sh mysql-to-doris.yaml


flink 配置如下，最后生效的是 execution_checkpointing

[AlexRoot]

从 checkpoint 中恢复，checkpoint 中有上次你消费的 kafka binlog offset, 或者是已经分好的 snapshot split.。

[qbmiller]

@AlexRoot 命令是什么样的。 ./bin/flink-cdc.sh mysql-to-doris.yaml -s file:///u01/flink/execution_checkpointing/<JobId>/chk-100 这样对吗，
我只会这样./bin/flink-cdc.sh mysql-to-doris.yaml 提交任务，

[soap0X]

问下 ai 一楼上面说的配置项，代码的话加行代码就可以了

[qbmiller]

@soap0X 非大数据开发人员。现在就是想用配置方式 ./bin/flink-cdc.sh mysql-to-doris.yaml 续传 跑起来。ai 各种都问了，不顶用。
我试试上边那个 -s 参数吧。

[AlexRoot]

@qbmiller #2 本质上是要让你的 flink 任务从 checkpoint 恢复，至于 flink-cdc.sh 这脚本支不支持从 checkpoint 恢复，要看脚本的内容。