你好，范瑞
Barrier alignment 这里并不会涉及 output/input queue，pending 的只是用于 alignment
的一小部分数据。
如果想了解 checkpoint 的原理，建议阅读文档中引用的两篇论文。[1] [2]
如果想了解 Flink 的具体实现，这里的文档是 internal 部分的，可能需要阅读一下相关代码了。[3] [4]
1. https://arxiv.org/abs/1506.08603
2.
Hi，老师：
老师，你好flink官网这个页面（https://ci.apache.org/projects/flink/flink-docs-release-1.8/internals/stream_checkpointing.htm）介绍barrier对齐的这里第三步
• Once the last stream has received barrier n, the operator emits all
pending outgoing records, and then emits snapshot n barriers itself.
