1 个回答
Flink Checkpoint支持两种语义,Exactly_Once 和 At_Least_Once。
这两种语义的区别主要在于对barrier对齐方式的处理,Exactly_Once的算子在接受到第一个barrier后会阻塞上游输入通道,将输入数据缓存起来,直到所有上游的barrier都收到之后才会继续处理这些数据。
At_Least_Once则不会阻塞上游数据,即使没有对齐barrier也会处理后续的数据。
这两种语义的区别主要在于对barrier对齐方式的处理,Exactly_Once的算子在接受到第一个barrier后会阻塞上游输入通道,将输入数据缓存起来,直到所有上游的barrier都收到之后才会继续处理这些数据。
At_Least_Once则不会阻塞上游数据,即使没有对齐barrier也会处理后续的数据。
发布于:3个月前 (02-06) IP属地:四川省
我来回答
您需要 登录 后回答此问题!