第三天:Flink的State、CheckPoint、Window窗口

5. Flink State管理跟恢復 Flink 是一個默認就有狀態的分析引擎,前面的 WordCount 案例能夠作到單詞的數量的累加,實際上是由於在內存中保證了每一個單詞的出現的次數,這些數據其實就是狀態數據。可是若是一個 Task 在處理過程當中掛掉了,那麼它在內存中的狀態都會丟失,全部的數據都須要從新計算。從容錯和消息處理的語義(At -least-once 和 Exactly-once
相關文章
相關標籤/搜索