View a markdown version of this page

升级 Studio 运行时 - Managed Service 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. 如果旧笔记本正在运行,请将其停止。根据需要启动新的笔记本以进行交互式使用。

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

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