Flink 的基石:Chandy Lamport Algorithm

Flink处理“流”,对流消息的处理支持三种级别语义分别是“At Most once、At Least once、Exactly once”。 At Most onces:消息最多被处理一次,sender发出消息之后,receiver无论是否处理成功,都不会再重发。类似于UDP协议的效果,只管发送,不管结果。 At Least once:消息至少被处理一次,sender发...