

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

# 将 Apache Beam 与 Managed Service for Apache Flink 应用程序结合使用
<a name="how-creating-apps-beam"></a>

**注意**  
**Flink 1.20 没有兼容的 Apache Flink 运行器。有关更多信息，请参阅 Apache Beam 文档中的 [Flink 版本兼容性](https://beam.apache.org/documentation/runners/flink/#flink-version-compatibility)。** >

您可以将 [Apache Beam](https://beam.apache.org/) 框架与 Managed Service for Apache Flink 应用程序一起使用来处理流数据。使用 Apache Beam 的 Managed Service for Apache Flink 应用程序使用 Apache [Flink 运行器](https://beam.apache.org/documentation/runners/flink/) 来执行 Beam 管道。

有关如何在 Managed Service for Apache Flink 应用程序中使用 Apache Beam 的教程，请参阅[使用 CloudFormation使用 Apache Beam 创建应用程序](examples-beam.md)。

**Topics**
+ [Apache Flink 运行器与 Managed Service Flink 结合使用时的限制](#how-creating-apps-beam-using)
+ [Apache Beam 面向 Managed Service for Apache Flink 的功能](#how-creating-apps-beam-capabilities)
+ [使用 Apache Beam 创建应用程序](examples-beam.md)

## Apache Flink 运行器与 Managed Service Flink 结合使用时的限制
<a name="how-creating-apps-beam-using"></a>

请注意以下有关使用 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 的功能
<a name="how-creating-apps-beam-capabilities"></a>

Managed Service for Apache Flink 支持与 Apache Flink 运行器相同的 Apache Beam 功能。有关 Apache Flink 运行器支持哪些功能的信息，请参阅 [Beam 兼容性矩阵](https://beam.apache.org/documentation/runners/capability-matrix/)。

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