Yarn.social Online Meetup 25th May (See: #fcghsma for details)

聊聊 Flink:Flink 的狀態管理
一、Flink 的狀態是什麼?—————我們知道,Flink 的一個算子可能會有多個子任務,每個子任務可能分佈在不同的實例(即 slot)上,我們可以把 Flink 的狀態理解爲某個算子的子任務在其當前實例上的一個變量,該變量記錄了流過當前實例算子的歷史記錄產生的結果。當新數據記錄流入時,我們需要結合該結果(即狀態,State)來進行計算。實際上,Flink 的狀態是由算子的子 ⌘ Read more

⤋ Read More