Realtime Compute for Apache Flink：作業引擎版本升級

步驟一：備份作業並部署新作業

為了確保作業啟動並執行穩定性，建議通過複製建立一個完全相同的新作業，並在新作業上進行作業引擎版本升級。

步驟二：老作業備份作業狀態

在營運中心 > 作業營運頁面，單擊目標作業，在作業詳情中的狀態集管理頁簽查看作業狀態集，詳情請參見查看狀態產生總覽。

• 如果您的作業屬於有狀態計算，那麼在升級版本時，首要考慮的是狀態能否複用。

  升級前請先手動產生一個作業快照，以便升級出現異常時可以快速復原業務。具體操作請參見手動建立作業快照。

  重要

  • 原則上同一大版本下的小版本間升級相容，大版本間升級不保證相容。如果相容，則新版本的引擎可以讀取舊版本引擎產生的作業快照，反之並不保證。

  • 從VVR 6.x版本起，系統支援原生格式和標準格式兩種作業快照格式。前者產生速度更快，後者相容性更好。因此，如果希望將作業的引擎版本升級至同一大版本下的更高小版本，建議在作業快照產生時選擇原生格式；如果希望將作業的引擎版本升級至更高的大版本，建議選擇標準格式。

• 如果您的作業是無狀態的，可以直接進入下一步。

（可選）步驟三：停止老作業

在營運中心 > 作業營運面，單擊老作業操作列下的停止。操作詳情請參見作業停止。

如果下遊寫入等冪或者業務上能接受重複資料，可以考慮新老作業同時運行。

步驟四：啟動新作業

• 如果您的作業是有狀態的：在有狀態啟動中選擇從指定狀態恢複，選擇老作業建立的作業快照。

• 如果您的作業是無狀態的，可以直接選擇無狀態啟動新作業。

作業啟動步驟詳情請參見作業啟動。

步驟五：觀察線上情況並刪除老作業

通常情況下，如果升級後作業可以正常啟動並完成第一個系統檢查點，可以視為升級初步成功。但仍然建議您觀察一下業務資料的正確性，以確保升級結果的完整性。

當作業正常運行且驗證資料正確性後，可以考慮手動刪除升級之前的作業快照及作業，作業快照刪除具體操作請參見手動刪除指定作業快照。