Verwenden Sie Apache Beam mit Managed Service für Apache Flink-Anwendungen - Managed Service für Apache Flink

Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Verwenden Sie Apache Beam mit Managed Service für Apache Flink-Anwendungen

Anmerkung

Apache Beam wird in Apache Flink Version 1.19 nicht unterstützt. Seit dem 27. Juni 2024 gibt es keinen kompatiblen Apache Flink Runner für Flink 1.18. Weitere Informationen finden Sie unter Flink-Versionskompatibilität in der Apache Beam-Dokumentation. >

Sie können das Apache Beam-Framework mit Ihrer Managed Service for Apache Flink-Anwendung verwenden, um Streaming-Daten zu verarbeiten. Managed Service für Apache Flink-Anwendungen, die Apache Beam verwenden, verwendet Apache Flink Runner zur Ausführung von Beam-Pipelines.

Ein Tutorial zur Verwendung von Apache Beam in einer Managed Service for Apache Flink-Anwendung finden Sie unterVerwenden CloudFormation.

Einschränkungen von Apache Flink Runner mit Managed Service für Apache Flink

Beachten Sie Folgendes zur Verwendung des Apache Flink Runners mit Managed Service für Apache Flink:

  • Apache Beam-Metriken sind in der Managed Service for Apache Flink-Konsole nicht sichtbar.

  • Apache Beam wird nur mit Managed Service für Apache Flink-Anwendungen unterstützt, die Apache Flink Version 1.8 und höher verwenden. Apache Beam wird mit Managed Service für Apache Flink-Anwendungen, die Apache Flink Version 1.6 verwenden, nicht unterstützt.

Apache Beam-Funktionen mit Managed Service für Apache Flink

Managed Service für Apache Flink unterstützt dieselben Apache Beam-Funktionen wie der Apache Flink Runner. Informationen darüber, welche Feature vom Apache Flink Runner unterstützt werden, finden Sie in der Beam-Kompatibilitätsmatrix.

Wir empfehlen Ihnen, Ihre Apache Flink-Anwendung im Managed Service for Apache Flink-Dienst zu testen, um sicherzustellen, dass wir alle Feature unterstützen, die Ihre Anwendung benötigt.