本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# 适用于 Apache Flink 2.3 的亚马逊托管服务
<a name="flink-2-3"></a>

Apache Flink 的托管服务现在支持 Apache Flink 版本 2.3.0。本节向您介绍在 Apache Flink 2.3.0 的支持 Flink 的 Managed Service for Apache Flink 中引入的关键新功能和更改。

**注意**  
如果你使用的是早期支持的Apache Flink版本并想将现有的应用程序升级到Apache Flink 2.3.0，则可以使用就地升级Apache Flink版本来实现。有关更多信息，请参阅 [使用 Apache Flink 的就地版本升级](how-in-place-version-upgrades.md)。通过就地版本升级，您可以针对单个 ARN 在 Apache Flink 版本中保持应用程序的可追溯性，包括快照、日志、指标、标签、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 和变更日志障碍 | 改进了将 CDC 或变更日志流写入 upsert sinks 时的更新顺序。 | [FLIP-558: 改进 SinkUpsertMaterializer 和变更日志障碍 ](https://cwiki.apache.org/confluence/display/FLINK/FLIP-558) | 
| 应用程序管理读取 API | 新的只读端点，可实现应用程序级可观测性。在 Apache Flink 的亚马逊托管服务中禁用了写入终端节点。 | [FLIP-549: 应用程序管理](https://cwiki.apache.org/confluence/display/FLINK/FLIP-549), [FLIP-560: 应用程序管理能力增强 ](https://cwiki.apache.org/confluence/x/5AAXG) | 
| 的自适应分区选择 StreamPartitioner | Opt-in 对倾斜`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#/)来选择加入以下功能：


**Opt-in 功能和相关文档**  

| Opt-in features | 说明 | Apache Flink 文档参考 | 
| --- | --- | --- | 
| 恢复期间的支持检查点 | 默认情况下，此功能处于禁用状态，因为它是开源中的实验性功能。您可以使用支持案例请求为您的应用程序启用它。 | [FLIP-547: 恢复期间的支持检查点 ](https://cwiki.apache.org/confluence/display/FLINK/FLIP-547) | 

有关 Apache Flink 2.3.0 版本文档，请参阅 [ Apache Flink 文档 v2.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/)

## 使用 Apache Flink 2.3 对适用于 Apache Flink 的亚马逊托管服务的更改
<a name="flink-2-3-changes"></a>

### 保留默认水印对齐方式
<a name="flink-2-3-watermark-alignment"></a>

Apache Flink 2.3 更改了水印对齐的默认行为，以防止积压的任务消耗所有下游资源。在适用于 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>


**适用于 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>

适用于 Apache Flink 的亚马逊托管服务不支持以下 Apache Flink 2.3 功能：
+ **物化表**：持续维护的可查询表快照。
+ **自定义遥测更改**：自定义指标报告器和遥测配置。
+ **Flink Native S3 FileSystem (FLIP-555)**：原生 S3 文件系统实现（开源实验版）
+ **ForSt 状态后端**：分解状态存储（在开源中处于实验阶段）。
+ **Java 21**：开源中的实验性支持，Apache Flink 的托管服务不支持。

## Amazon Managed Service for Apache Flink Studio
<a name="flink-2-3-known-issues-studio"></a>

适用于 Apache 的亚马逊托管服务 Flink 中的 Flink 2.3 不支持 Studio 应用程序。有关更多信息，请参阅[创建 Studio 笔记本](https://docs.aws.amazon.com/managed-flink/latest/java/how-zeppelin-creating.html)。