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

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

This topic created in 153 days ago, the information mentioned may be changed or developed.

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

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

MySQL

doris

flink-cdc

5 replies

AlexRoot

Jan 13

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

qbmiller

Jan 13

@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

Jan 13

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

qbmiller

Jan 13

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

AlexRoot

Jan 14

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

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

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