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

# Amazon Managed Service for Apache Flink 1.15
<a name="flink-1-15-2"></a>

 Managed Service for Apache Flink 支持 Apache 1.15.2 中的以下新功能：


****  

| 功能 | 说明 | Apache FLIP 参考  | 
| --- | --- | --- | 
| 异步接收器  | 一个用于构建异步目标的 Amazon 贡献框架，允许开发人员以不到先前一半的工作量来构建自定义 Amazon 连接器。有关更多信息，请参阅[通用异步基础接收器](https://flink.apache.org/2022/05/06/async-sink-base.html)。 | [FLIP-171: Async Sink](https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink)。 | 
| Kinesis Data Firehose 接收器  | Amazon 使用异步框架贡献了一个新的 Amazon Kinesis Firehose Sink。 | [Amazon Kinesis Data Firehose 接收器](https://nightlies.apache.org/flink/flink-docs-release-1.15//docs/connectors/datastream/firehose/)。 | 
| 停止运行 SavePoint  | Stop with Savepoint 可确保干净的停止操作，最重要的是为依赖它们的客户支持一次性语义。 | [FLIP-34: Terminate/Suspend Job with SaveP](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=103090212) oint。 | 
| Scala 解耦  | 用户现在可以利用任何 Scala 版本的 Java API，包括 Scala 3。客户需要将自己选择的 Scala 标准库捆绑到他们的 Scala 应用程序中。 | [FLIP-28: 制作 flink-t Scala-free able 的 Long-term 目标](https://cwiki.apache.org/confluence/display/FLINK/FLIP-28%3A+Long-term+goal+of+making+flink-table+Scala-free)。 | 
| Scala | 参见上面的 Scala 解耦  | [FLIP-28: 制作 flink-t Scala-free able 的 Long-term 目标](https://cwiki.apache.org/confluence/display/FLINK/FLIP-28%3A+Long-term+goal+of+making+flink-table+Scala-free)。 | 
| 统一连接器指标 | Flink 为任务、任务和运算符[定义了标准指标](https://nightlies.apache.org/flink/flink-docs-release-1.15//docs/ops/metrics/)。Managed Service for Apache Flink 将继续支持接收器和源指标，并在 1.15 中与可用性指标numRestarts并行fullRestarts引入。 | [FLIP-33：标准化连接器指标](https://cwiki.apache.org/confluence/display/FLINK/FLIP-33%3A+Standardize+Connector+Metrics)和 [FLIP-179：公开标准化操作员指标](https://cwiki.apache.org/confluence/display/FLINK/FLIP-179%3A+Expose+Standardized+Operator+Metrics)。 | 
| 检查已完成的任务  | 此功能在 Flink 1.15 中默认处于启用状态，即使任务图的某些部分已完成所有数据的处理，也可以继续执行检查点，如果它包含有界（批处理）源，则可能会发生这种情况。 | [FLIP-147: 任务完成后的 Support 检查点](https://cwiki.apache.org/confluence/display/FLINK/FLIP-147%3A+Support+Checkpoints+After+Tasks+Finished)。 | 

## 针对 Apache Flink 1.15，Amazon Managed Service for Apache Flink 更改
<a name="flink-1-15-2-changes"></a>

**Studio 笔记本**

现在，Managed Service for Apache Flink Studio 支持 Apache Flink 1.15。Managed Service for Apache Flink Studio 利用 Apache Zeppelin 笔记本为开发、调试代码和运行 Apache Flink 流处理应用程序提供单一界面开发体验。要详细了解 Managed Service for Apache Flink Studio 以及如何开始使用[将 Studio 笔记本与 Managed Service for Apache Flink 结合使用](how-notebook.md)。

**EFO 连接器**

升级到 Managed Service for Apache Flink 版本 1.15 时，请确保使用的是最新的 EFO Connector，即任何版本 1.15.3 或更高版本。有关原因的更多信息，请参阅[FLINK-29324](https://issues.apache.org/jira/browse/FLINK-29324 )。

**Scala 解耦**

从 Flink 1.15.2 开始，您需要在 Scala 应用程序中捆绑您选择的 Scala 标准库。

**Kinesis Data Firehose 接收器**

升级到 Managed Service for Apache Flink 版本 1.15 时，请确保使用的是最新的[Amazon Kinesis Data Firehose 接收器](https://nightlies.apache.org/flink/flink-docs-release-1.15//docs/connectors/datastream/firehose/)。

**Kafka 连接器**

升级到 Amazon Managed Service for Apache Flink 1.15 版时，请确保使用的是最新的Amazon Kinesis Data Firehose 接收器。Apache Flink 已弃用 [FlinkKafkaConsumer](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-consumer)，[FlinkKafkaProducer](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-producer)这些用于 Kafka sink 的 API 无法提交到 Flink 1.15 的 Kafka。确保您正在使用[KafkaSource](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-source)和[KafkaSink](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-sink)。

## 组件
<a name="flink-1-15-2-components"></a>


****  

| 组件 | 版本 | 
| --- | --- | 
| Java  | 11（推荐使用） | 
| Scala | 2.12 | 
| Managed Service for Apache Flink Flink 运行时系统 (aws-kinesisanalytics-runtime) | 1.2.0 | 
| [Amazon Kinesis 连接器（flink-connector-kinnector](https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kinesis/1.15.4) | 1.15.4 | 
| [Apache Beam（仅限 Beam 应用程序）](https://www.amazonaws.cn/developer/language/python/) | 2.33.0，Jackson 版本 2.12.2 | 

## 已知问题
<a name="flink-1-15-known-issues"></a>

**代理重新启动后 Kafka 提交检查点操作反复失败**

Flink 版本 1.15 中的 Apache Kafka 连接器存在已知的开源 Apache Flink 问题，这是由于 Kafka Client 2.8.1 中的一个严重开源 Kafka Client 错误造成的。有关更多信息，请参阅 [Kafka Commit，了解代理重启后检查点反复失败](https://issues.apache.org/jira/browse/FLINK-28060)，[提交OffsetAsync 异常后无法恢复与组协调器的连接](https://issues.apache.org/jira/browse/KAFKA-13840)。KafkaConsumer 

为避免此问题，我们建议您在 Amazon Managed Service for Apache Flink 中使用 Apache Flink 1.18 或更高版本。