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

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

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

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

MySQL

doris

flink-cdc

2 条回复

AlexRoot

4 小时 28 分钟前

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

qbmiller

3 小时 59 分钟前

@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 提交任务，

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

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