假设你的checkpoint设置为每10分钟一次那假设5分钟的时候算子出了异常请问此时flink会如何处理?
当Flink作业运行时,每10分钟会生成一个checkpoint。如果在第5分钟时发生了异常,Flink会根据配置的重试策略进行重试。重试的次数和时间间隔可以根据配置进行调整,默认情况下最多重试3次。如果在最大重试次数内仍然无法成功,Flink会将作业标记为失败,并根据配置的失败处理策略进行处理,例如重新启动作业或者停止作业。
原文地址: https://www.cveoy.top/t/topic/i02e 著作权归作者所有。请勿转载和采集!