分类： Flink

一、前言 当发生任务失败时,Flink 需要重启失败的任务和其他受影响的任务,以使作业恢复到正常状态。 重启策略和故障转移策略用于控制任务重启。重启策略决定失败/受影响的任务是否以及何时可以重启。故障…

一、前言 正常情况下，对齐检查点的时间主要由检查点过程中的同步部分和异步部分所决定。然而，当Flink任务在严重的反压下运行时，检查点从头到尾的时间的决定性因素可能是将检查点屏障传播到所有算子/子任务…

Flink官网 http://flink.apache.org Flink项目理念 Apache Flink 是为分布式、高性能、随时可用以及准确的流处理应用程序打造的开源流处理框架。Flink 用同…