View a markdown version of this page

Amazon Managed Service for Apache Flink 2.3 - Managed Service for Apache Flink
支援的功能Amazon Managed Service for Apache Flink with Apache Flink 2.3 的變更元件不支援和實驗性功能Amazon Managed Service for Apache Flink Studio

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

Amazon Managed Service for Apache Flink 2.3

Managed Service for Apache Flink 現在支援 Apache Flink 2.3.0 版。本節將介紹 Managed Service for Apache Flink 2.3.0 支援的主要新功能和變更。

注意

如果您使用的是舊版支援的 Apache Flink，並且想要將現有應用程式升級至 Apache Flink 2.3.0，您可以使用就地 Apache Flink 版本升級來執行此操作。如需詳細資訊，請參閱針對 Apache Flink 使用就地版本升級。透過就地版本升級，您可以針對跨 Apache Flink 版本的單一 ARN 保留應用程式可追蹤性，包括快照、日誌、指標、標籤、Flink 組態等。

注意

從 Flink 1.x 升級到 Flink 2.3 是主要版本升級，具有重大變更和狀態相容性考量。從 1.x 升級之前，請檢閱 打破變更和棄用和 。 Flink 2.2 升級的狀態相容性指南

Apache Flink 2.3.0 在 SQL API、針對扭曲工作負載的自適應分割區選擇，以及 Flink 儀表板中引入了改進。

支援的功能和相關文件

支援的功能

說明

Apache Flink 文件參考

SinkUpsertMaterializer 和 changelog 障礙的改善

改善將 CDC 或 changelog 串流寫入 upsert 接收器時的更新順序。

FLIP-558：SinkUpsertMaterializer 和 changelog 障礙的改善

Application Management APIs

用於應用程式層級可觀測性的新唯讀端點。Amazon Managed Service for Apache Flink 中已停用寫入端點。

FLIP-549：Application Management、FLIP-560：Application Management Capability Enhancement

StreamPartitioner 的自適應分割區選擇

選擇加入偏斜Rebalance和Rescale分割器的輸送量最佳化。預設停用；使用 啟用 taskmanager.network.adaptive-partitioner.enabled。

FLIP-339：StreamPartitioner 的自適應分割區選擇
注意

您可以透過提交支援案例來選擇加入下列功能：

選擇加入功能和相關文件

選擇加入功能

說明

Apache Flink 文件參考

在復原期間支援檢查點

這是預設停用的，因為它是開放原始碼中的實驗性功能。您可以使用支援案例請求 為您的應用程式啟用它。

FLIP-547：在復原期間支援檢查點

如需 Apache Flink 2.3.0 版本文件，請參閱 Apache Flink 文件 2.3.0 版。如需 Flink 2.3 版本備註，請參閱版本備註 - Flink 2.3。

Apache Flink 2.3 會變更浮水印對齊的預設行為，以防止待處理的任務耗用所有下游資源。在 Amazon Managed Service for Apache Flink 中，預設值 pipeline.watermark-alignment.max-drift 設定為 0，以保持與先前支援的 Apache Flink 版本的回溯相容性，並在升級時保護您現有的應用程式免於行為回歸。如果您想要新的公平行為，您可以在應用程式程式碼中pipeline.watermark-alignment.max-drift以程式設計方式設定 來選擇加入。如需詳細資訊，請參閱 FLINK-37399：浮水印對齊可防止待處理任務使用所有資源。

Amazon Managed Service for Apache Flink 2.3 的元件

元件

版本

Java

17 （建議）

Python

3.12

Kinesis Data Analytics Flink 執行期 (aws-kinesisanalytics-runtime)

1.2.0

連接器

如需可用連接器的資訊，請參閱 Apache Flink 連接器。

Amazon Managed Service for Apache Flink 不支援下列 Apache Flink 2.3 功能：

  • 具體化資料表：持續維護、可查詢的資料表快照。

  • 自訂遙測變更：自訂指標報告程式和遙測組態。

  • Flink Native S3 FileSystem (FLIP-555)：原生 S3 檔案系統實作 （在開放原始碼中進行實驗）

  • ForSt 狀態後端：分解狀態儲存 （在開放原始碼中進行實驗）。

  • Java 21：開放原始碼中的實驗性支援，在 Managed Service for Apache Flink 中不支援。

Amazon Managed Service for Apache Flink 中的 Flink 2.3 不支援 Studio 應用程式。如需詳細資訊，請參閱建立 Studio 筆記本。