

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

# Amazon Managed Service for Apache Flink 2.3
<a name="flink-2-3"></a>

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 使用就地版本升級](how-in-place-version-upgrades.md)。透過就地版本升級，您可以針對跨 Apache Flink 版本的單一 ARN 保留應用程式可追蹤性，包括快照、日誌、指標、標籤、Flink 組態等。

**注意**  
從 Flink 1.x 升級到 Flink 2.3 是主要版本升級，具有重大變更和狀態相容性考量。從 1.x 升級之前，請檢閱 [打破變更和棄用](flink-2-2.md#flink-2-2-breaking-changes)和 。 [Flink 2.2 升級的狀態相容性指南](state-compatibility.md)

## 支援的功能
<a name="flink-2-3-supported-features"></a>

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


**支援的功能和相關文件**  

| 支援的功能 | 說明 | Apache Flink 文件參考 | 
| --- | --- | --- | 
| SinkUpsertMaterializer 和 changelog 障礙的改善 | 改善將 CDC 或 changelog 串流寫入 upsert 接收器時的更新順序。 | [FLIP-558：SinkUpsertMaterializer 和 changelog 障礙的改善](https://cwiki.apache.org/confluence/display/FLINK/FLIP-558) | 
| Application Management APIs | 用於應用程式層級可觀測性的新唯讀端點。Amazon Managed Service for Apache Flink 中已停用寫入端點。 | [FLIP-549：Application Management](https://cwiki.apache.org/confluence/display/FLINK/FLIP-549)、[FLIP-560：Application Management Capability Enhancement](https://cwiki.apache.org/confluence/x/5AAXG) | 
| StreamPartitioner 的自適應分割區選擇 | 選擇加入偏斜`Rebalance`和`Rescale`分割器的輸送量最佳化。預設停用；使用 啟用 `taskmanager.network.adaptive-partitioner.enabled`。 | [FLIP-339：StreamPartitioner 的自適應分割區選擇](https://cwiki.apache.org/confluence/display/FLINK/FLIP-339) | 

**注意**  
您可以透過提交[支援案例](https://console.aws.amazon.com/support/home#/)來選擇加入下列功能：


**選擇加入功能和相關文件**  

| 選擇加入功能 | 說明 | Apache Flink 文件參考 | 
| --- | --- | --- | 
| 在復原期間支援檢查點 | 這是預設停用的，因為它是開放原始碼中的實驗性功能。您可以使用支援案例請求 為您的應用程式啟用它。 | [FLIP-547：在復原期間支援檢查點](https://cwiki.apache.org/confluence/display/FLINK/FLIP-547) | 

如需 Apache Flink 2.3.0 版本文件，請參閱 [Apache Flink 文件 2.3.0 版。](https://nightlies.apache.org/flink/flink-docs-release-2.3/)如需 Flink 2.3 版本備註，請參閱[版本備註 - Flink 2.3。](https://nightlies.apache.org/flink/flink-docs-stable/release-notes/flink-2.3/)

## Amazon Managed Service for Apache Flink with Apache Flink 2.3 的變更
<a name="flink-2-3-changes"></a>

### 保留浮水印對齊預設
<a name="flink-2-3-watermark-alignment"></a>

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：浮水印對齊可防止待處理任務使用所有資源](https://issues.apache.org/jira/browse/FLINK-37399)。

## 元件
<a name="flink-2-3-components"></a>


**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 連接器](https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html)。 | 

## 不支援和實驗性功能
<a name="flink-2-3-unsupported"></a>

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 Studio
<a name="flink-2-3-known-issues-studio"></a>

Amazon Managed Service for Apache Flink 中的 Flink 2.3 不支援 Studio 應用程式。如需詳細資訊，請參閱[建立 Studio 筆記本](https://docs.aws.amazon.com/managed-flink/latest/java/how-zeppelin-creating.html)。