Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
升級 Studio 執行期
本節包含如何升級 Studio 筆記本執行期的相關資訊。建議您一律升級至最新的支援的 Studio Runtime。
將筆記本升級至新的 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 功能相容。
-
執行新的筆記本。開啟筆記本並依備註、順序執行,並測試其是否有效。
-
對程式碼進行任何必要的變更。
-
停止新的筆記本。
-
-
如果您已將舊筆記本部署為應用程式:
-
將新筆記本部署為獨立的新應用程式。
-
停止舊應用程式。
-
在沒有快照的情況下執行新應用程式。
-
-
如果舊筆記本正在執行,請將其停止。視需要啟動新的筆記本以供互動式使用。
使用外部相依性進行升級的處理流程