將 Apache Beam 與 Managed Service for Apache Flink 應用程式搭配使用 - Managed Service for Apache Flink
使用 Managed Service for Apache Flink 的 Apache Flink Runner 限制使用 Managed Service for Apache Flink 的 Apache Beam 功能

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

將 Apache Beam 與 Managed Service for Apache Flink 應用程式搭配使用

注意

Apache Flink 1.19 版不支援 Apache Beam。截至 2024 年 6 月 27 日，沒有適用於 Flink 1.18 的相容 Apache Flink Runner。如需詳細資訊，請參閱 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。

本主題包含下列章節：

使用 Managed Service for Apache Flink 的 Apache Flink Runner 限制

請注意下列有關將 Apache Flink 執行器與 Managed Service for Apache Flink 搭配使用的相關資訊：

  • 在 Managed Service for Apache Flink 主控台中無法檢視 Apache Beam 指標。

  • 只有使用 Apache Flink 1.8 及以上版本的 Managed Service for Apache Flink 應用程式才支援 Apache Beam。使用 Apache Flink 1.6 版的 Managed Service for Apache Flink 應用程式不支援 Apache Beam。

使用 Managed Service for Apache Flink 的 Apache Beam 功能

Managed Service for Apache Flink 與 Apache Flink 執行器支援相同的 Apache Beam 功能。如需 Apache Flink 執行器所支援功能的相關資訊，請參閱 Beam 相容性矩陣。

建議您在 Managed Service for Apache Flink 服務中測試 Apache Flink 應用程式，以確認我們是否支援您的應用程式所需的全部功能。