升級 Studio 執行期 - Managed Service for Apache Flink

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

升級 Studio 執行期

本節包含如何升級 Studio 筆記本執行期的相關資訊。我們建議您一律升級至最新支援的 Studio 執行期。

將您的筆記本升級至新的 Studio 執行期

視您使用 Studio 的方式而定,升級執行期的步驟會有所不同。選取符合您使用案例的選項。

如果您使用的 SQL 或 Python 沒有任何外部相依性,請使用下列執行期升級程序。我們建議您升級至最新的 Runtime 版本。升級程序與您要升級的執行期版本相同,無延遲。

  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. 如果舊筆記本正在執行,請將其停止。視需要啟動新的筆記本以供互動式使用。

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

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