Flink中配置非对齐的checkpoint，磁盘会一直增长吗？

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

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

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

在Flink中，如果配置了非对齐的checkpoint，磁盘可能会一直增长，因为Flink会将checkpoint写入磁盘，而这些checkpoint会占用磁盘空间。然而，这并不是Flink的一个缺陷，而是由于Flink的设计和工作原理导致的。
为了解决这个问题，可以考虑以下几种方式：

1. 使用对齐的checkpoint：Flink支持对齐的checkpoint，这种方式可以确保每个checkpoint只占用磁盘空间的一部分，从而减少磁盘空间的占用。
2. 使用定期清理策略：Flink允许用户设置定期清理策略，例如可以设置每天或每周清理一次checkpoint，从而减少磁盘空间的占用。
3. 使用外部存储：Flink支持使用外部存储来存储checkpoint，例如可以使用HDFS或S3等分布式存储系统来存储checkpoint，从而减少磁盘空间的占用。