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 功能相容。
-
執行新的筆記本。打開筆記本並按照筆記順序運行它,並測試它是否有效。
-
對程式碼進行任何必要的變更。
-
停止新的筆記本。
-
-
如果您已將舊筆記型電腦部署為應用程式:
-
將新的筆記本部署為單獨的新應用程式。
-
停止舊的應用程式。
-
執行不含快照的新應用程式。
-
-
如果舊筆記本正在運行,請停止它。視需要啟動新筆記本以供互動使用。
使用外部相依性升級的程序流程