将 Apache Beam 与 Managed Service for Apache Flink 应用程序结合使用 - Managed Service for Apache Flink
Apache Flink 运行器与 Managed Service Flink 结合使用时的限制Apache Beam 面向 Managed Service for Apache Flink 的功能
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon Managed Service for Apache Flink（Amazon MSF）之前称为 Amazon Kinesis Data Analytics for Apache Flink。

将 Apache Beam 与 Managed Service for Apache Flink 应用程序结合使用

注意

Flink 1.20 没有兼容的 Apache Flink 运行器。有关更多信息，请参阅 Apache Beam 文档中的 Flink 版本兼容性。 >

您可以将 Apache Beam 框架与 Managed Service for Apache Flink 应用程序一起使用来处理流数据。使用 Apache Beam 的 Managed Service for Apache Flink 应用程序使用 Apache Flink 运行器 来执行 Beam 管道。

有关如何在 Managed Service for Apache Flink 应用程序中使用 Apache Beam 的教程，请参阅使用 CloudFormation。

本主题包含下列部分：

Apache Flink 运行器与 Managed Service Flink 结合使用时的限制

请注意以下有关使用 Apache Flink 运行器和 Managed Service for Apache Flink的信息：

  • Apache Beam 指标无法在 Managed Service for Apache Flink 控制台中查看。

  • Managed Service for Apache Flink 现在支持使用 Apache Flink 版本 1.8 的应用程序。Managed Service for Apache Flink 现在支持使用 Apache Flink 版本 1.6 的应用程序。

Apache Beam 面向 Managed Service for Apache Flink 的功能

Managed Service for Apache Flink 支持与 Apache Flink 运行器相同的 Apache Beam 功能。有关 Apache Flink 运行器支持哪些功能的信息，请参阅 Beam 兼容性矩阵。

我们建议您在 Managed Service for Apache Flink 中测试您的 Apache Flink 应用程序，以验证我们是否支持您的应用程序所需的所有功能。