升級工作室運行 - Managed Service for Apache Flink

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

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

升級工作室運行

本節包含有關如何升級您的 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. 如果舊筆記本正在運行,請停止它。視需要啟動新的筆記本以供互動使用。

使用外部相依性升級的程序流程

下圖顯示使用外部相依性升級筆記本的建議工作流程。