Flink流計算編程--狀態與檢查點

一、Exactly_once簡介 Exactly_once語義是Flink的特性之一,那麼Flink到底提供了什麼層次的Excactly_once?有人說是是每一個算子保證只處理一次,有人說是每條數據保證只處理一次。其實理解這個語義並不難,直接在官方文檔中就能夠看出: html 從圖中能夠看出:Exactly_once是爲有狀態的計算準備的!java 換句話說,沒有狀態的算子操做(operator
相關文章
相關標籤/搜索