apache-flink - Flink 在检查点失败时不会失败
问题描述
根据 Apache Flink 文档,有一个参数failOnCheckpointingErrors(当前已弃用但仍受支持),如果它是真正的工作,如果它无法创建检查点(超时或异常),则应该失败。但实际上它不会发生。
谁能指出我的假设哪里错了?
解决方案
Job will fail only in case of CHECKPOINT_DECLINED
what happens if the was an exception during checkpoint execution.
If checkpoint didn't succeed because of timeout the cause is CHECKPOINT_EXPIRED
which doesn't increment failure count.
推荐阅读
- python - 我想更新字典。但它的生成,RuntimeError: dictionary changed size during iteration
- python - 将记录添加到 MySQL 后立即更新 Flask 页面
- android - 如何使用 MockK 模拟构建器以使构建器函数可交换?
- flutter - showBottomSheet 看不到 currentState
- inheritance - 视图控制器模型的继承
- flutter - 在构建错误期间调用了我的 setState() 或 markNeedsBuild()。你能帮我么?
- opengl - 用OpenGL绘制彩色网格?
- excel - VBA VLookup 按列名
- flutter - 将 Intent 网址转换为 Android Intent
- excel - 为什么 Msgbox 会损坏 Date 变量