升级 Studio 运行时 - Managed Service for Apache Flink
将您的笔记本升级到新的 Studio 运行时

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

升级 Studio 运行时

本部分包含有关如何升级 Studio 笔记本运行时的信息。我们建议您始终升级到最新支持的 Studio 运行时。

将您的笔记本升级到新的 Studio 运行时

根据您使用 Studio 的方式，升级运行时的步骤会有所不同。选择适用于使用案例的选项：

如果您正在使用没有任何外部依赖关系的 SQL 或 Python，请使用以下运行时升级过程。建议您升级到最新的运行时版本。无论您要升级哪个运行时版本，升级过程均相同。

  1. 使用最新的运行时创建新的 Studio 笔记本。

  2. 将旧笔记本中每条备注的代码复制并粘贴到新笔记本上。

  3. 在新笔记本中，调整代码，使其兼容与先前版本相比已更改的任何 Apache Flink 功能。

    • 运行新笔记本。打开笔记本并按顺序逐条运行备注，然后测试它是否正常运作。

    • 对代码进行任何必要的更改。

    • 停止运行新笔记本。

  4. 如果您已将旧笔记本部署为应用程序：

    • 将新笔记本部署为单独的新应用程序。

    • 停止运行旧应用程序。

    • 在没有快照的情况下运行新应用程序。

  5. 如果旧笔记本正在运行，请将其停止。根据需要启动新的笔记本以进行交互式使用。

在没有外部依赖关系的情况下升级的过程流程

下图显示在没有外部依赖关系的情况下升级笔记本的建议工作流程。

如果您使用 SQL 或 Python 并使用外部依赖项，例如连接器或自定义构件（示例包括以 Python 或 Java 实施的用户定义函数），则请遵循此过程。建议您升级到最新的运行时。无论您从哪个运行时版本进行升级，升级过程均相同。

  1. 使用最新的运行时创建新的 Studio 笔记本。

  2. 将旧笔记本中每条备注的代码复制并粘贴到新笔记本上。

  3. 更新外部依赖关系和自定义构件。

    • 寻找与新运行时的 Apache Flink 版本兼容的新连接器。请参阅 Apache Flink 文档中的表和 SQL 连接器，寻找适用于 Flink 版本的正确连接器。

    • 更新用户定义函数的代码，使其与 Apache Flink API 中的更改以及用户定义函数使用的任何 Python 或 JAR 依赖关系相匹配。重新打包更新的自定义构件。

    • 将这些新的连接器和构件添加到新笔记本中。

  4. 在新笔记本中，调整代码，使其兼容与先前版本相比已更改的任何 Apache Flink 功能。

    • 运行新笔记本。打开笔记本并按顺序逐条运行备注，然后测试它是否正常运作。

    • 对代码进行任何必要的更改。

    • 停止运行新笔记本。

  5. 如果您已将旧笔记本部署为应用程序：

    • 将新笔记本部署为单独的新应用程序。

    • 停止运行旧应用程序。

    • 在没有快照的情况下运行新应用程序。

  6. 如果旧笔记本正在运行，请将其停止。根据需要启动新的笔记本以进行交互式使用。

在有外部依赖关系的情况下升级的过程流程

下图显示在没有外部依赖关系的情况下升级笔记本的建议工作流程。