首页 > 解决方案 > Flink 在检查点失败时不会失败

问题描述

根据 Apache Flink 文档,有一个参数failOnCheckpointingErrors(当前已弃用但仍受支持),如果它是真正的工作,如果它无法创建检查点(超时或异常),则应该失败。但实际上它不会发生。

谁能指出我的假设哪里错了?

标签: apache-flinkflink-streaming

解决方案


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.


推荐阅读