Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。
本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
使用 Apache Beam 创建 Managed Service for Apache Flink
您可以将 Apache Beam
有关如何在 Managed Service for Apache Flink 应用程序中使用 Apache Beam 的教程,请参阅将 CloudFormation 与 Managed Service for Apache Flink 结合使用。
将 Apache Beam 与 Managed Service for Apache 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 的应用程序。
Beam 功能
Managed Service for Apache Flink 支持与 Apache Flink 运行器相同的 Apache Beam 功能。有关 Apache Flink 运行器支持哪些功能的信息,请参阅 Beam 兼容性矩阵
我们建议您在 Managed Service for Apache Flink 中测试您的 Apache Flink 应用程序,以验证我们是否支持您的应用程序所需的所有功能。