昨天面試別人說他熟悉Flink，結果我問了他Flink是如何實現exactly-once語義的？

Flink跟其餘的流計算引擎相比,最突出或者作的最好的就是狀態的管理.面試 什麼是狀態呢?好比咱們在平時的開發中,須要對數據進行count,sum,max等操做,這些中間的結果(便是狀態)是須要保存的,由於要不斷的更新,這些值或者變量就能夠理解爲是一種狀態,拿讀取kafka爲例,咱們須要記錄數據讀取的位置(便是偏移量),並保存offest,這時offest也能夠理解爲是一種狀態.算法 Flink是

>>阅读原文<<