flink1.10checkpoint及savepoint實戰

代碼中配置狀態後端和checkpoint的間隔時間及相關配置 1.flink-conf.yaml中配置Savepoint存儲位置 不是必須設置,但是設置後,後面創建指定Job的Savepoint時,可以不用在手動執行命令時指定Savepoint的位置 2.取消任務並將savepoint保存到指定文件夾中 3.從指定的路徑加載savepoint啓動應用 4.注意:從savepoint中加載狀態是通過
相關文章
相關標籤/搜索