使用 Apache Flink 的就地版本升级来升级应用程序 - Managed Service for Apache Flink
升级之前：更新你的 Apache Flink 应用程序
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

使用 Apache Flink 的就地版本升级来升级应用程序

在开始之前，我们建议您观看以下视频：就地版本升级。

要对 Apache Flink 执行就地版本升级，可以使用 Amazon CLI、 Amazon CloudFormation Amazon SDK、或。 Amazon Web Services Management Console您可以将此功能与处于READY或RUNNING状态的 Apache Flink 托管服务一起使用的任何现有应用程序一起使用。它使用 UpdateApplication API添加更改 Flink 运行时的功能。

升级之前：更新你的 Apache Flink 应用程序

在编写 Flink 应用程序时，您可以将它们与其依赖项捆绑到应用程序中，JAR然后将其上传JAR到您的 Amazon S3 存储桶。然后，适用于 Apache Flink 的亚马逊托管服务将在您选择的新 Flink 运行时中运行该作业。您可能需要更新应用程序，以实现与要升级到的 Flink 运行时的兼容性。Flink 版本之间可能存在不一致，导致版本升级失败。最常见的是，这将使用源（入口）或目的地（接收器、出口）的连接器以及 Scala 依赖关系。适用于 Apache Flink 的托管服务中的 Flink 1.15 及更高版本与 Scala 无关，你JAR必须包含计划使用的 Scala 版本。

更新您的应用程序

  1. 阅读 Flink 社区关于使用状态升级应用程序的建议。请参阅升级应用程序和 Flink 版本。

  2. 阅读已知问题和限制清单。请参阅 应用程序升级的注意事项和已知问题。

  3. 更新您的依赖关系并在本地测试您的应用程序。这些依赖关系通常是：

    1. Flink 运行时和. API

    2. 建议在新的 Flink 运行时中使用连接器。您可以在要更新到的特定运行时的发布版本中找到这些内容。

    3. Scala — Apache Flink 从 Flink 1.15 开始并包括 Flink 1.15 就与 Scala 无关。您必须包括要在应用程序JAR中使用的 Scala 依赖项。

  4. 在 zipfile JAR 上构建一个新应用程序并将其上传到 Amazon S3。我们建议您使用与之前的 JAR /zipfile 不同的名称。如果您需要回滚，则将使用此信息。

  5. 如果您正在运行有状态的应用程序，我们强烈建议您拍摄当前应用程序的快照。如果在升级期间或升级之后遇到问题，这可以让你有状态地回滚。