Checkpoint 慢之Barrier 对齐慢如何解决？

从前面我们知道 Checkpoint 在 task 端分为 barrier 对齐（收齐所有上游发送 过来的 barrier），然后开始同步阶段，再做异步阶段。如果 barrier 一直对不齐的话， 就不会开始做 snapshot。 barrier 对齐之后会有如下日志打印：

DEBUG
Starting checkpoint (6751) CHECKPOINT on task taskNameWithSubtasks (4/4)

如果 taskmanager.log 中没有这个日志，则表示 barrier 一直没有对齐，接 下来我们需要了解哪些上游的 barrier 没有发送下来，如果你使用 At Least Once 的 话，可以观察下面的日志：

DEBUG
Received barrier for checkpoint 96508 from channel 5

表示该 task 收到了 channel 5 来的 barrier，然后看对应 Checkpoint，再查看 还剩哪些上游的 barrier 没有接受到，对于 ExactlyOnce 暂时没有类似的日志，可 以考虑自己添加，或者 jmap 查看.