Flink Checkpoint支持哪些语义?

提问者:帅平 问题分类:面试刷题
Flink Checkpoint支持哪些语义?
1 个回答
人潮似水看见我°
人潮似水看见我°
Flink Checkpoint支持两种语义,Exactly_Once 和 At_Least_Once。
这两种语义的区别主要在于对barrier对齐方式的处理,Exactly_Once的算子在接受到第一个barrier后会阻塞上游输入通道,将输入数据缓存起来,直到所有上游的barrier都收到之后才会继续处理这些数据。
At_Least_Once则不会阻塞上游数据,即使没有对齐barrier也会处理后续的数据。
发布于:3个月前 (02-06) IP属地:四川省
我来回答