Flink基于checkpoint的容错机制是一项标志性功能。因为这一设计，Flink统一了批流处理，能够很容易扩展到极小和极大场景并支持许多类似状态演化实现有状态升级和回滚及时间穿梭的操作功能。 尽管有这些很棒的特性，Flink的checkpoint方式有一个致命弱点：checkpoint速度取决与数据流过整个应用的速度。当应用发生背压时，checkpoint也同样被压（附录1概括了什么是背压，为什么背压可能是好事）。在这种情况下，checkpoint可能会花费更多时间，甚至会超时。 在Flink 1.11版本，社区引入了一个新特性“非对齐checkpoint”来解决这一问题，在Flink […]