Managed Service for Apache Flink アプリケーションで Apache Beam を使用する - Managed Service for Apache Flink
Managed Service for Apache Flink を使用した Apache Flink ランナーの制限事項Managed Service for Apache Flink を使用した Apache Beam の機能

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Managed Service for Apache Flink アプリケーションで Apache Beam を使用する

注記

Apache Beam は Apache Flink バージョン 1.19 ではサポートされていません。2024 年 6 月 27 日現在、Flink 1.18 と互換性のある Apache Flink Runner はありません。詳細については、Apache Beam ドキュメントの「Flink バージョンの互換性」を参照してください。＞

「Apache Beam」フレームワークを Apache Flink アプリケーション用 Managed Serviceで使用して、ストリーミングデータを処理できます。Apache Beam を使用する Apache Flink アプリケーション用 Managed Serviceでは、「Apache Flink ランナー」を使用して Beam パイプラインを実行します。

Apache Flink アプリケーション用 Managed Serviceで Apache Beam を使用する方法に関するチュートリアルについては、 を使用する CloudFormation を参照してください。

このトピックには、次のセクションが含まれています。

Managed Service for Apache Flink を使用した Apache Flink ランナーの制限事項

Apache Flink 用 Managed Serviceで Apache Flink ランナーを使用する際には、次の点に注意してください。

  • Apache Beam メトリクスは Apache Flink 用 Managed Serviceコンソールでは表示できません。

  • 「Apache Beam は Apache Flink バージョン 1.8 以降を使用する Apache Flink アプリケーション用 Managed Serviceでのみサポートされています。」 「Apache Beam は、Apache Flink バージョン 1.6 を使用する Apache Flink アプリケーション用 Managed Serviceではサポートされていません。」

Managed Service for Apache Flink を使用した Apache Beam の機能

Apache Flink のマネージドサービスは、Apache Flink ランナーと同じ Apache Beam 能力をサポートしています。Apache Flink ランナーでサポートされている機能については、「ビーム互換性マトリックス」を参照してください。

Apache Flink 用 Managed Serviceで Apache Flink アプリケーションをテストして、アプリケーションに必要なすべての機能がサポートされていることを確認することをお勧めします。