Flink中配置非对齐的checkpoint，磁盘会一直增长吗？[阿里云实时计算 Flink版] 暂停朗读为您朗读

在Flink中，非对齐检查点（Unaligned Checkpoint）主要是为了解决在高反压情况下作业难以完成Checkpoint的问题。通过这种方式，可以有效地避免Checkpoint可能带来的阻塞，从而提高Flink的资源利用率。然而，这种机制是以磁盘资源为代价的，因为非对齐检查点需要额外保存数据流的现场，可能会导致总的状态大小有明显的膨胀，从而增加磁盘压力。

当任务从非对齐检查点恢复时，除了对齐检查点涉及的Source端重放和算子的计算状态恢复之外，未对齐的流数据也会被恢复到各个链路，三者合并起来就是能够保证exactly once的完整现场。

为了解决这个问题，Flink 1.11引入了非对齐检查点（unaligned checkpoint）的特性，取消了屏障对齐操作：当算子的所有输入流中的第一个屏障到达算子的输入缓冲区时，立即将这个屏障发往下游（输出缓冲区）。这种机制可以优化高反压情况下的Checkpoint表现。