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 2.3
Managed Service für Apache Flink unterstützt jetzt Apache Flink Version 2.3.0. In diesem Abschnitt werden die wichtigsten neuen Funktionen und Änderungen vorgestellt, die mit der Unterstützung von Apache Flink 2.3.0 durch Managed Service for Apache Flink eingeführt wurden.
Anmerkung
Wenn Sie eine frühere unterstützte Version von Apache Flink verwenden und Ihre vorhandenen Anwendungen auf Apache Flink 2.3.0 aktualisieren möchten, können Sie dazu direkte Apache Flink-Versionsupgrades verwenden. Weitere Informationen finden Sie unter Verwenden Sie direkte Versionsupgrades für Apache Flink. Mit direkten Versionsupgrades behalten Sie die Rückverfolgbarkeit von Anwendungen anhand eines einzigen ARN für alle Apache Flink-Versionen, einschließlich Snapshots, Logs, Metriken, Tags, Flink-Konfigurationen und mehr.
Anmerkung
Das Upgrade von Flink 1.x auf Flink 2.3 ist ein wichtiges Versionsupgrade mit grundlegenden Änderungen und Überlegungen zur Statuskompatibilität. Bevor Sie ein Upgrade von 1.x durchführen, überprüfen Sie und. Wichtige Änderungen und veraltete Versionen Leitfaden zur staatlichen Kompatibilität für Flink 2.2-Upgrades
Unterstützte Features
Apache Flink 2.3.0 bietet Verbesserungen an der SQL-API, der adaptiven Partitionsauswahl für schiefe Workloads und dem Flink-Dashboard.
Unterstützte Features |
Description |
Referenz zur Apache Flink-Dokumentation |
|---|---|---|
Verbesserungen an SinkUpsertMaterializer und Changelog-Unordnung |
Verbessert die Reihenfolge der Updates beim Schreiben von CDC- oder Changelog-Streams auf Upsert-Senken. |
FLIP-558: Verbesserungen bei der Changelog-Störung SinkUpsertMaterializer |
Anwendungsmanagement liest APIs |
Neue schreibgeschützte Endpunkte für Beobachtbarkeit auf Anwendungsebene. Schreibendpunkte sind in Amazon Managed Service für Apache Flink deaktiviert. |
FLIP-549: Anwendungsmanagement |
Adaptive Partitionsauswahl für StreamPartitioner |
Opt-in Durchsatzoptimierung für schiefe Partitionierer |
Anmerkung
Sie können sich für die folgenden Funktionen entscheiden, indem Sie eine Support-Anfrage einreichen
Opt-in features |
Description |
Referenz zur Apache Flink-Dokumentation |
|---|---|---|
Support Sie den Checkpoint während der Wiederherstellung |
Dies ist standardmäßig deaktiviert, da es sich um eine experimentelle Funktion in Open Source handelt. Sie können mithilfe einer Support-Anfrage die Aktivierung für Ihre Anwendung beantragen. |
FLIP-547: Support Sie den Checkpoint während der Wiederherstellung |
Die Apache Flink 2.3.0-Release-Dokumentation finden Sie unter Apache Flink
Änderungen in Amazon Managed Service für Apache Flink mit Apache Flink 2.3
Die Standardausrichtung des Wasserzeichens wurde beibehalten
Apache Flink 2.3 ändert das Standardverhalten der Ausrichtung von Wasserzeichen, um zu verhindern, dass im Rückstand befindliche Jobs alle nachgelagerten Ressourcen verbrauchen. In Amazon Managed Service für Apache Flink pipeline.watermark-alignment.max-drift ist der Standardwert von so eingestellt, dass 0 die Abwärtskompatibilität mit früheren unterstützten Apache Flink-Versionen erhalten bleibt und Ihre vorhandenen Anwendungen beim Upgrade vor einer Verhaltensregression geschützt werden. Wenn Sie das neue Fairness-Verhalten wünschen, können Sie sich dafür entscheiden, indem Sie es pipeline.watermark-alignment.max-drift programmgesteuert in Ihrem Anwendungscode festlegen. Weitere Informationen finden Sie unter FLINK-37399: Durch die Ausrichtung von Wasserzeichen wird verhindert, dass Aufträge, die im Rückstand sind, alle Ressourcen nutzen
Komponenten
Komponente |
Version |
|---|---|
Java |
17 (empfohlen) |
Python |
3.12 |
Kinesis Data Analytics Flink-Laufzeit (aws-kinesisanalytics-runtime) |
1.2.0 |
Konnektoren |
Informationen zu verfügbaren Konnektoren finden Sie unter Apache Flink-Konnektoren. |
Nicht unterstützte und experimentelle Funktionen
Die folgenden Funktionen von Apache Flink 2.3 werden in Amazon Managed Service für Apache Flink nicht unterstützt:
Materialisierte Tabellen: Kontinuierlich verwaltete, abfragbare Tabellen-Snapshots.
Benutzerdefinierte Telemetrieänderungen: Benutzerdefinierte Metrik-Reporter und Telemetriekonfigurationen.
-
Flink Native S3 FileSystem (FLIP-555): Implementierung eines systemeigenen S3-Dateisystems (experimentell in Open Source)
-
ForSt State-Backend: Disaggregierter Statusspeicher (experimentell in Open Source).
-
Java 21: Experimentelle Unterstützung in Open Source, nicht unterstützt in Managed Service für Apache Flink.
Amazon-Managed-Service für Apache Flink
Flink 2.3 in Amazon Managed Service für Apache Flink unterstützt keine Studio-Anwendungen. Weitere Informationen finden Sie unter Ein Studio-Notizbuch erstellen.
