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.
Amazon Managed Service für Apache Flink 1.20
Managed Service für Apache Flink unterstützt jetzt Apache Flink Version 1.20.5. In diesem Abschnitt werden die wichtigsten neuen Funktionen und Änderungen vorgestellt, die mit der Unterstützung von Apache Flink 1.20.5 durch Managed Service for Apache Flink eingeführt wurden. Apache Flink 1.20 wird voraussichtlich die letzte 1.x-Version und eine Flink Long-Term Support (LTS) -Version sein. Weitere Informationen finden Sie unter FLIP-458: Long-Term Unterstützung für die endgültige Version von Apache Flink 1.x Line.
Anmerkung
Wenn Sie eine frühere unterstützte Version von Apache Flink verwenden und Ihre vorhandenen Anwendungen auf Apache Flink 1.20.5 aktualisieren möchten, können Sie dies mithilfe von direkten Apache Flink-Versionsupgrades tun. Weitere Informationen finden Sie unter Verwenden Sie direkte Versionsupgrades für Apache Flink. Mit direkten Versionsupgrades behalten Sie die Rückverfolgbarkeit Ihrer Anwendungen anhand eines einzigen ARN für alle Apache Flink-Versionen bei, einschließlich Snapshots, Logs, Metriken, Tags, Flink-Konfigurationen und mehr.
Unterstützte Features
Apache Flink 1.20.5 führt Verbesserungen in den SQL-APIs, in den APIs und im Flink-Dashboard ein. DataStream
| Unterstützte Features | Description | Referenz zur Apache Flink-Dokumentation |
|---|---|---|
| DISTRIBUTED BY-Klausel hinzufügen | Viele SQL-Engines bieten die Konzepte vonPartitioning,Bucketing, oderClustering. Flink 1.20 führt das Konzept von Bucketing in Flink ein. |
FLIP-376: DISTRIBUTED BY-Klausel hinzufügen |
| DataStream API: Unterstützt die vollständige Partitionsverarbeitung | Flink 1.20 führt über die API eine integrierte Unterstützung für Aggregationen in Streams ohne Schlüssel ein. FullPartitionWindow |
FLIP-380: Unterstützt die vollständige Partitionsverarbeitung auf Non-keyed DataStream |
| Zeigt den Wert für den Datenversatz im Flink Dashboard an | Das Flink 1.20-Dashboard zeigt jetzt Informationen zur Datenverzerrung an. Jeder Bediener auf der Benutzeroberfläche des Flink-Jobdiagramms zeigt einen zusätzlichen Wert für die Datenverzerrung an. | FLIP-418: Zeigt den Wert für die Datenverzerrung im Flink-Dashboard an |
Die Apache Flink 1.20.5-Release-Dokumentation finden Sie in der Apache Flink Documentation v1.20.5 auf der
Komponenten
| Komponente | Version |
|---|---|
| Java | 11 (empfohlen) |
| Python |
3.11 |
| Kinesis Data Analytics Flink-Laufzeit (aws-kinesisanalytics-runtime) | 1.2.0 |
| Konnektoren | Informationen zu verfügbaren Konnektoren finden Sie unter Apache Flink-Konnektoren. https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html |
| Apache Beam (nur Beam-Anwendungen) |
Ab Version 2.70.0. Weitere Informationen finden Sie unter Flink-Versionskompatibilität. |
Bekannte Probleme
Von Amazon verwalteter Dienst für Apache Flink Studio
Amazon Managed Service für Apache Flink Studio verwendet Apache Zeppelin-Notebooks, um eine zentrale Entwicklungsumgebung für die Entwicklung, das Debuggen von Code und die Ausführung von Apache Flink-Stream-Verarbeitungsanwendungen bereitzustellen. Für den Flink Interpreter von Zeppelin ist ein Upgrade erforderlich, um die Unterstützung von Flink 1.20 zu aktivieren. Diese Arbeit ist mit der Zeppelin-Community geplant. Wir werden diese Hinweise aktualisieren, sobald diese Arbeiten abgeschlossen sind. Sie können Flink 1.15 weiterhin mit Amazon Managed Service für Apache Flink Studio verwenden. Weitere Informationen finden Sie unter Ein Studio-Notizbuch erstellen.
Fehlerkorrekturen wurden zurückportiert
Amazon Managed Service für Apache Flink meldet Fehlerbehebungen aus der Flink-Community für kritische Probleme zurück. Im Folgenden finden Sie eine Liste der Bugfixes, die wir zurückportiert haben:
| Apache Flink JIRA-Verbindung | Description |
|---|---|
| FLINK-35886 |
Mit diesem Fix wird ein Problem behoben, das dazu führt, dass Zeitüberschreitungen beim Leerlauf von Wasserzeichen falsch berechnet werden, wenn eine Unteraufgabe ausgeführt wird. backpressured/blocked |
