View a markdown version of this page

Amazon Managed Service für Apache Flink 2.3 - Managed Service für Apache Flink

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 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 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.

Anmerkung

Das Upgrade von Flink 1.x auf Flink 2.3 ist ein umfangreiches Versionsupgrade mit wichtigen Änderungen und Überlegungen zur Zustandskompatibilitä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

Apache Flink 2.3.0 führt Verbesserungen in der SQL-API, der adaptiven Partitionsauswahl für schiefe Workloads und dem Flink-Dashboard ein.

Unterstützte Funktionen und zugehörige Dokumentation

Unterstützte Features

Description

Referenz zur Apache Flink-Dokumentation

Verbesserungen SinkUpsertMaterializer und Changelog-Störung

Verbessert die Reihenfolge der Updates beim Schreiben von CDC- oder Changelog-Streams in Upsert-Sinks.

FLIP-558: Verbesserungen und Changelog-Störung SinkUpsertMaterializer

Anwendungsmanagement: Lesen Sie APIs

Neue schreibgeschützte Endpunkte für Beobachtbarkeit auf Anwendungsebene. Schreibendpunkte sind in Amazon Managed Service für Apache Flink deaktiviert.

FLIP-549: Anwendungsmanagement, FLIP-560: Erweiterung der Anwendungsverwaltungsfunktionen

Adaptive Partitionsauswahl für StreamPartitioner

Opt-in Durchsatzoptimierung für Skewed Rebalance und Rescale Partitioner. Standardmäßig deaktiviert; aktiviert mit. taskmanager.network.adaptive-partitioner.enabled

FLIP-339: Adaptive Partitionsauswahl für StreamPartitioner

Anmerkung

Sie können sich für die folgenden Funktionen entscheiden, indem Sie eine Support-Anfrage einreichen:

Opt-in Funktionen und zugehörige Dokumentation

Opt-in features

Description

Referenz zur Apache Flink-Dokumentation

Unterstützt 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 beantragen, sie für Ihre Anwendung zu aktivieren.

FLIP-547: Unterstützen Sie den Checkpoint während der Wiederherstellung

Die Apache Flink 2.3.0-Release-Dokumentation finden Sie in der Apache Flink Documentation v2.3.0. Versionshinweise zu Flink 2.3 finden Sie unter Versionshinweise — Flink 2.3.

Apache Flink 2.3 ändert das Standardverhalten der Wasserzeichenausrichtung, um zu verhindern, dass rückständige Jobs alle Downstream-Ressourcen verbrauchen. In Amazon Managed Service für Apache Flink pipeline.watermark-alignment.max-drift ist der Standardwert von so festgelegt, dass die Abwärtskompatibilität mit früheren unterstützten Apache Flink-Versionen gewahrt bleibt und Ihre vorhandenen Anwendungen beim Upgrade vor einer Verhaltensregression geschützt werden. 0 Wenn Sie das neue Fairness-Verhalten wünschen, können Sie sich dafür anmelden, indem Sie dies pipeline.watermark-alignment.max-drift programmgesteuert in Ihrem Anwendungscode festlegen. Weitere Informationen finden Sie unter FLINK-37399: Die Ausrichtung von Wasserzeichen verhindert, dass rückständige Jobs alle Ressourcen beanspruchen.

Komponenten für Amazon Managed Service für Apache Flink 2.3

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. https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html

Die folgenden Apache Flink 2.3-Funktionen werden in Amazon Managed Service für Apache Flink nicht unterstützt:

  • Materialisierte Tabellen: Kontinuierlich gepflegte, abfragbare Tabellen-Snapshots.

  • Änderungen an der benutzerdefinierten Telemetrie: Benutzerdefinierte Metrik-Reporter und Telemetriekonfigurationen.

  • Flink Native S3 FileSystem (FLIP-555): Native S3-Dateisystemimplementierung (experimentell in Open Source)

  • ForSt State Backend: Disaggregierter Zustandsspeicher (experimentell in Open Source).

  • Java 21: Experimentelle Unterstützung in Open Source, nicht unterstützt in 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.