

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

# Managed Service for Apache Flink アプリケーションに Apache Beam を使用する
<a name="how-creating-apps-beam"></a>

**注記**  
**Flink 1.20 と互換性のある Apache Flink Runner はありません。詳細については、「Apache Beam ドキュメント」の「[Flink Version Compatibility](https://beam.apache.org/documentation/runners/flink/#flink-version-compatibility)」を参照してください。**>

「[Apache Beam](https://beam.apache.org/)」フレームワークを Apache Flink アプリケーション用 Managed Serviceで使用して、ストリーミングデータを処理できます。Apache Beam を使用する Apache Flink アプリケーション用 Managed Serviceでは、「[Apache Flink ランナー](https://beam.apache.org/documentation/runners/flink/)」を使用して Beam パイプラインを実行します。

Apache Flink アプリケーション用 Managed Serviceで Apache Beam を使用する方法に関するチュートリアルについては、 [CloudFormation を使用するApache Beam を使用してアプリケーションを作成する](examples-beam.md) を参照してください。

**Topics**
+ [Managed Service for Apache Flink を使用した Apache Flink ランナーの制限事項](#how-creating-apps-beam-using)
+ [Managed Service for Apache Flink での Apache Beam 機能](#how-creating-apps-beam-capabilities)
+ [Apache Beam を使用してアプリケーションを作成する](examples-beam.md)

## Managed Service for Apache Flink を使用した Apache Flink ランナーの制限事項
<a name="how-creating-apps-beam-using"></a>

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 機能
<a name="how-creating-apps-beam-capabilities"></a>

Apache Flink のマネージドサービスは、Apache Flink ランナーと同じ Apache Beam 能力をサポートしています。Apache Flink ランナーでサポートされている機能については、「[ビーム互換性マトリックス](https://beam.apache.org/documentation/runners/capability-matrix/)」を参照してください。

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