Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
升級工作室運行
本節包含有關如何升級您的 Studio 筆記本運行時的信息。我們建議您一律升級至最新支援的 Studio 執行階段。
將您的筆記本升級到新的 Studio 運行時
根據您使用 Studio 的方式,升級執行階段的步驟會有所不同。選取適合您使用案例的選項。
如果您使用的 SQL 或 Python 沒有任何外部相依性,請使用下列執行階段升級程序。我們建議您升級至最新的執行階段版本。升級程序與您要從中升級的執行階段版本相同,無後端。
-
使用最新的執行階段建立新的 Studio 筆記本。
-
將舊筆記本中每個記事的代碼複製並粘貼到新筆記本中。
-
在新筆記本中,調整程式碼,使其與舊版變更的任何 Apache Flink 功能相容。
-
執行新的筆記本。打開筆記本並按照筆記順序運行它,並測試它是否有效。
-
對程式碼進行任何必要的變更。
-
停止新的筆記本。
-
-
如果您已將舊筆記型電腦部署為應用程式:
-
將新的筆記本部署為單獨的新應用程式。
-
停止舊的應用程式。
-
執行不含快照的新應用程式。
-
-
如果舊筆記本正在運行,請停止它。視需要啟動新的筆記本以供互動使用。
無需外部依賴關係即可升級的流程
如果您使用 SQL 或 Python 並使用外部相依性 (例如連接器或自訂成品),例如使用 Python 或 Java 實作的使用者定義函式,請遵循此程序。我們建議您升級至最新的執行階段。無論您要從哪個執行階段版本升級,程序都是相同的。
-
使用最新的執行階段建立新的 Studio 筆記本。
-
將舊筆記本中每個記事的代碼複製並粘貼到新筆記本中。
-
更新外部相依性和自訂人工因素。
-
尋找與新執行階段 Apache Flink 版本相容的新連接器。請參閱 Apache Flink 文件中的資料表和 SQL 連接器
,以尋找適用於 Flink 版本的正確連接器。 -
更新使用者定義函數的程式碼,以符合 Apache Flink API 中的變更,以及使用者定義函數使用的任何 Python 或 JAR 相依性。重新封裝您更新的自訂成品。
-
將這些新的連接器和加工品新增至新的筆記本。
-
-
在新筆記本中,調整程式碼,使其與舊版變更的任何 Apache Flink 功能相容。
-
執行新的筆記本。打開筆記本並按照筆記順序運行它,並測試它是否有效。
-
對程式碼進行任何必要的變更。
-
停止新的筆記本。
-
-
如果您已將舊筆記型電腦部署為應用程式:
-
將新的筆記本部署為單獨的新應用程式。
-
停止舊的應用程式。
-
執行不含快照的新應用程式。
-
-
如果舊筆記本正在運行,請停止它。視需要啟動新的筆記本以供互動使用。
使用外部相依性升級的程序流程