應用程式升級的一般最佳實務和建議 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

應用程式升級的一般最佳實務和建議

  • 在嘗試生產升級之前，在非生產環境中測試新任務/執行時間，但沒有狀態。

  • 考慮先使用非生產應用程式測試狀態升級。

  • 請確定您的新任務圖表與用來啟動升級應用程式的快照狀態相容。

    • 確保存放在運算子狀態中的類型保持不變。如果類型已變更，則 Apache Flink 無法還原運算子狀態。

    • 請確定IDs您使用 uid方法設定的運算子保持不變。Apache Flink 強烈建議將唯一指派給IDs運算子。如需詳細資訊，請參閱 Apache Flink 文件中的指派運算子IDs。

      如果您未IDs指派給運算子，Flink 會自動產生這些運算子。在這種情況下，它們可能取決於程式結構，如果變更，可能會導致相容性問題。Flink 使用運算子IDs將快照中的狀態與運算子比對。變更運算子IDs會導致應用程式未啟動，或快照中存放的狀態遭到捨棄，而新的運算子在沒有狀態的情況下啟動。

    • 請勿變更用於存放鍵控狀態的金鑰。

    • 請勿修改狀態運算子的輸入類型，例如視窗或聯結。這隱含地變更了運算子的內部狀態類型，導致狀態不相容。