从checkpoint恢复作业,可否改变并行度?

来源:16-8 重启策略测试

kingdomad

2020-10-14

如题。
老师可否增加一些课程内容讲一下从checkpoint或者savepoint恢复作业的案例,包括如何在原有的flink程序上做迭代后,在原有的savepoint上启动一个新的flink程序,最佳实践要怎么操作。

写回答

1回答

Michael_PK

2020-10-15

就是启动参数上加个-s指定你上次运行到的最新的chk目录就可以了呢。所有的state不管是keyed还是operator的都自动在chk里面了。

0
0

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程