更新时间:2024-01-17 GMT+08:00
Flink作业重启后,如何判断是否可以从checkpoint恢复
什么是从checkpoint恢复?
Flink Checkpoint 是一种容错恢复机制。这种机制保证了实时程序运行时,遇到异常或者机器问题时能够进行自我恢复。
从checkpoint恢复的原则
- 通常当作业执行失败、资源异常重启等非人为触发的异常场景时,支持从checkpoint恢复。
- 但是如果修改了作业的运算逻辑,作业的计算逻辑已发生更改,不支持从checkpoint恢复。
父主题: 运维指导
运维指导 所有常见问题
- Flink作业提交错误,如何定位
- Flink作业运行异常,如何定位
- Flink作业重启后,如何判断是否可以从checkpoint恢复
- 作业语义检验时提示DIS通道不存在怎么处理?
- 如何处理作业的OBS Bucket没有授权?
- DLI Flink作业提交运行后(已选择保存作业日志到OBS桶),提交运行失败的情形(例如:jar包冲突),有时日志不会写到OBS桶中
- Kafka Sink配置发送失败重试机制
- 访问FlinkUI/SparkUI页面无法正常显示怎么办?
- Jobmanager与Taskmanager心跳超时,导致Flink作业异常怎么办?
- Flink jobmanager日志一直报Timeout expired while fetching topic metadata怎么办?
more