Amazon Managed Service for Apache Flink (Amazon MSF) 先前稱為 Amazon Kinesis Data Analytics for Apache Flink。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
升級 Studio 執行期
本節包含如何升級 Studio 筆記本執行期的相關資訊。我們建議您一律升級至最新支援的 Studio 執行期。
將您的筆記本升級至新的 Studio 執行期
視您使用 Studio 的方式而定,升級執行期的步驟會有所不同。選取符合您使用案例的選項。
如果您使用的 SQL 或 Python 沒有任何外部相依性,請使用下列執行期升級程序。我們建議您升級至最新的 Runtime 版本。升級程序與您要升級的執行期版本相同,無延遲。
-
使用最新的執行期建立新的 Studio 筆記本。
-
將每個備註的程式碼從舊筆記本複製並貼到新筆記本。
-
在新的筆記本中,調整程式碼,使其與先前版本變更的任何 Apache Flink 功能相容。
-
執行新的筆記本。開啟筆記本並依備註、依序執行,並測試它是否有效。
-
對程式碼進行任何必要的變更。
-
停止新的筆記本。
-
-
如果您已將舊筆記本部署為應用程式:
-
將新的筆記本部署為獨立的新應用程式。
-
停止舊的應用程式。
-
在沒有快照的情況下執行新應用程式。
-
-
如果舊筆記本正在執行,請將其停止。視需要啟動新的筆記本以供互動式使用。
無需外部相依性即可升級的處理流程

如果您使用 SQL 或 Python,並使用連接器或自訂成品等外部相依性,例如在 Python 或 Java 中實作的使用者定義函數,請遵循此程序。我們建議您升級至最新的執行期。無論您要從哪個執行期版本升級,此程序都相同。
-
使用最新的執行期建立新的 Studio 筆記本。
-
將每個備註的程式碼從舊筆記本複製並貼到新筆記本。
-
更新外部相依性和自訂成品。
-
尋找與新執行時間的 Apache Flink 版本相容的新連接器。請參閱 Apache Flink 文件中的資料表和 SQL 連接器
,以尋找 Flink 版本的正確連接器。 -
更新使用者定義函數的程式碼,以符合 Apache Flink API 中的變更,以及使用者定義函數使用的任何 Python 或 JAR 相依性。重新封裝更新後的自訂成品。
-
將這些新的連接器和成品新增至新的筆記本。
-
-
在新的筆記本中,調整程式碼,使其與先前版本變更的任何 Apache Flink 功能相容。
-
執行新的筆記本。開啟筆記本並依備註、依序執行,並測試它是否有效。
-
對程式碼進行任何必要的變更。
-
停止新的筆記本。
-
-
如果您已將舊筆記本部署為應用程式:
-
將新的筆記本部署為獨立的新應用程式。
-
停止舊的應用程式。
-
在沒有快照的情況下執行新應用程式。
-
-
如果舊筆記本正在執行,請將其停止。視需要啟動新的筆記本以供互動式使用。
使用外部相依性進行升級的程序流程
