适用于 Apache Flink 2.2 的亚马逊托管服务

现在，当客户尝试通过或类似方式修改 MSF 不支持的配置时，MSF Flink 2.2 会报告异常。env.getConfig().set() APIs请参阅编程 Flink 配置属性。

客户仍然可以通过支持票证请求更改某些配置（请参阅可修改的设置）

该fullRestarts指标已在 Flink 2.2 中删除。改用该numRestarts指标。

在 Flink 连接器版本 6.0.0（仅与 Flink 2.2 兼容的 AWS 连接器版本）中，KDS 连接器的bytesRequestedPerFetch指标已被删除。

在 Flink 2.2 中，uptime和downtime指标都被标记为已弃用，并将很快被删除。uptime替换为新的指标runningTime。downtime替换为restartingTimecancellingTime、和中的一个或多个failingTime。

有关支持的指标的完整列表，请参阅指标和维度页面。

AWS SDK DefaultCredentialsProvider(/latest/meta-data/iam/security-credentials/) 和 DefaultAwsRegionProviderChain(/latest/dynamic/instance-identity/document) 使用这些允许的终端节点来自动为您的应用程序配置凭证和区域。

使用依赖非凭证 IMDS 调用（例如EC2MetadataUtils.getInstanceId()、、或EC2MetadataUtils.getAvailabilityZone()）的 AWS 开发工具包函数的应用程序在EC2MetadataUtils.getInstanceType()尝试EC2MetadataUtils.getLocalHostName()这些调用时将收到 HTTP 4xx 错误。

如果您的应用程序使用 IMDS 来存储元数据或允许路径之外的其他信息，请重构您的代码以改用环境变量或应用程序配置。

为了提高安全性，任何依赖项之外是默认/tmp的 flink 工作目录，都将导致:java.io.FileNotFoundException: /{path}/{filename} (Read-only file system).

文件系统依赖关系可以直接源自您的代码，也可以间接源于依赖项中包含的库。重写代码/tmp/中的直接文件系统依赖关系。对于来自库的间接文件系统依赖关系，请使用库配置覆盖将文件系统操作重定向到。/tmp/

Flink 2.0+ 版本中已完全删除了用于批处理的旧版 DataSet API。现在，所有批处理都必须使用统一的 DataStream API。

在升级之前，必须将使用 DataSet API 的应用程序迁移到 DataStream API。要进行转换，请参阅 Apache Flink 迁移指南 DataSet DataStream

Java 11 支持已完全移除；Java 17 是默认运行时和推荐运行时。

已移除 Python 3.8 支持；Python 3.12 现在是默认设置。

旧版SourceFunction和SinkFunction接口已被新的统一 Source (FLIP-27) 和 Sink (FLIP-143) 所取代 APIs，它们为 bounded/unbounded 二元性提供了更好的支持、改进的检查点协调和更简洁的编程模型。

对于 Kinesis Data Streams，KinesisStreamsSource请使用KinesisStreamsSink和来自。flink-connector-aws-kinesis-streams:6.0.0-2.0

Flink Scala API 已被移除。Flink 的 Java API 现在是基于 JVM 的应用程序支持的单一 API。

如果你的应用程序是用 Scala 编写的，你仍然可以使用 Scala 代码中的 Flink 的 Java API ——主要的变化是 Scala 特有的包装器和隐式转换不再可用。有关更新 Scala 应用程序的详细信息，请参阅升级应用程序和 Flink 版本。

从版本 2.24 升级到 5.6 的 Kryo 序列化器可能会导致状态兼容性问题。

POJOs with 集合 (HashMapArrayList、、HashSet) 可能存在状态兼容性问题。

Avro 和 Protobuf 的序列化不受影响。

有关Flink 2.2 升级的状态兼容性指南对应用程序风险级别进行分类的详细评估，请参阅。

如果您的应用程序依赖的连接器还没有 Flink 2.x 版本，则有两种选择：等待连接器发布兼容版本，或者评估是否可以将其替换为替代版本（例如，使用 JDBC 目录或自定义接收器）。

更新连接器版本时，请注意工件名称的更改——某些连接器在主要版本之间已重命名（例如，flink-connector-aws-firehose在某些中间版本中，Firehose 连接器从flink-connector-aws-kinesis-firehose变为）。

请务必查看 A pache Flink 连接器的亚马逊托管服务文档，了解目标运行时支持的确切工件名称和版本。

物化表：持续维护、可查询的表快照。

自定义遥测更改：自定义指标报告器和遥测配置。

ForSt 状态后端：分解状态存储（开源实验版）。

Java 21：开源中的实验性支持，Apache Flink 托管服务不支持。

当 Kinesis KinesisStreamsSource 直播进行重新分片时，使用连接器 v5.0.0 和 v6.0.0 中引入的 with EFO（增强型扇出/ SubscribeToShard）路径的应用程序可能会失败。这是社区中的一个已知问题。有关更多信息，请参阅 FLINK-37648。

如果 Flink 应用程序处于背压之下，则使用连接器 v5.0.0 和 v6.0.0 中引入的 with EFO（增强型扇出/ SubscribeToShard）路径的应用程序KinesisStreamsSink可能会遇到死锁，从而导致一个或多个应用程序的数据处理完全停止。KinesisStreamsSource TaskManagers恢复应用程序需要强制停止操作和启动应用程序操作。这是社区中已知问题的一个子案例。有关更多信息，请参阅 FLINK-34071。

Flink 2.2 的新手？ 有关 Apache Flink 2.2 文档的详细信息，请参阅 A pache Fl ink 2.2 文档。

计划升级？ 请参阅 升级到 Flink 2.2：完整指南。

状态兼容性问题？ 请参阅 Flink 2.2 升级的状态兼容性指南。