使用 Apache Flink 的就地版本升級來升級應用程式 - Managed Service for Apache Flink
升級前：更新您的 Apache Flink 應用程式

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

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

使用 Apache Flink 的就地版本升級來升級應用程式

在開始之前，我們建議您觀看此視頻：就地版本升級。

若要針對 Apache Flink 執行就地版本升級，您可以使用 AWS CLI AWS CloudFormation AWS SDK、、或. AWS Management Console您可以在READY或RUNNING狀態下搭配 Apache Flink 管理服務使用的任何現有應用程式使用此功能。它會使用 UpdateApplication API來新增變更 Flink 執行階段的能力。

升級前：更新您的 Apache Flink 應用程式

撰寫 Flink 應用程式時，您可JAR以將它們及其相依性捆綁到應用程式中，JAR然後上傳到 Amazon S3 儲存貯體。從那裡，適用於 Apache Flink 的 Amazon 受管服務會在您選擇的新 Flink 執行階段中執行任務。您可能必須更新應用程式，才能與要升級至的 Flink 執行階段相容。Flink 版本之間可能存在不一致的情況，導致版本升級失敗。最常見的是，這將與來源（入口）或目的地（接收器，出口）和 Scala 依賴關係的連接器。Apache Flink 的管理服務中的 Flink 1.15 及更高版本是不可知的，並且您JAR必須包含您打算使用的 Scala 版本。

更新您的應用程式

  1. 閱讀 Flink 社區關於使用狀態升級應用程序的建議。請參閱升級應用程式和 Flink 版本。

  2. 閱讀了解問題和限制的列表。請參閱 應用程式升級時的注意事項和已知。

  3. 更新您的相依性並在本機測試應用程式。這些依賴關係通常是：

    1. Flink 執行階段和API.

    2. 建議用於新 Flink 執行階段的連接器。您可以在要更新到的特定運行時的發布版本中找到這些內容。

    3. 斯卡拉-阿帕奇 Flink 是與標準不可知論者開始，包括 Flink 1.15。您必須包含要在應用程序中使用的 Scala 依賴關係JAR。

  4. JAR在 zip 檔案上建立新的應用程式，並將其上傳到 Amazon S3。我們建議您使用與之前的 JAR /zipfile 不同的名稱。如果您需要回滾，則將使用此信息。

  5. 如果您正在執行可設定狀態的應用程式，我們強烈建議您建立目前應用程式的快照。如果在升級期間或之後遇到問題，這可讓您以狀態方式回復。