flink狀態後端statebackend管理,容錯以及升級程序注意事項

Flink-StateBackend 視頻地址 MemoryStateBackend 特點 基於JVM堆內存,會有oom風險(TM,JM) 持久化時,State網絡傳輸到JM機器,同樣存在JM的內存中 適用 開發測試 狀態小的流計算場景,比如比如只包含數據過濾和轉換以及數據源的消費位置 FsStateBackend 特點 基於JVM堆內存,會有oom風險(TM) 持久化時,State存在TM的文件

>>阅读原文<<