昨天面试别人说他熟悉Flink，结果我问了他Flink是如何实现exactly-once语义的？

Flink跟其余的流计算引擎相比,最突出或者作的最好的就是状态的管理.面试 什么是状态呢?好比咱们在平时的开发中,须要对数据进行count,sum,max等操做,这些中间的结果(便是状态)是须要保存的,由于要不断的更新,这些值或者变量就能够理解为是一种状态,拿读取kafka为例,咱们须要记录数据读取的位置(便是偏移量),并保存offest,这时offest也能够理解为是一种状态.算法 Flink是

>>阅读原文<<