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
Unterstützte Features
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 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 |
Adaptive Partitionsauswahl für StreamPartitioner |
Opt-in Durchsatzoptimierung für Skewed |
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 |
|---|---|---|
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.
Ä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 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
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 |
Nicht unterstützte und experimentelle Funktionen
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.
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.