Aktualisieren Sie Anwendungen mithilfe von direkten Versionsupgrades für Apache Flink - Managed Service für Apache Flink
Vor dem Upgrade: Aktualisieren Sie Ihre Apache Flink-Anwendung

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.

Aktualisieren Sie Anwendungen mithilfe von direkten Versionsupgrades für Apache Flink

Bevor Sie beginnen, empfehlen wir Ihnen, sich dieses Video anzusehen: Direkte Versionsupgrades.

Um direkte Versionsupgrades für Apache Flink durchzuführen, können Sie AWS CLI, AWS CloudFormation AWS SDK, oder die verwenden. AWS Management Console Sie können diese Funktion mit allen vorhandenen Anwendungen verwenden, die Sie mit Managed Service for Apache Flink im Status oder verwenden. READY RUNNING Es verwendet die UpdateApplication API, um die Möglichkeit hinzuzufügen, die Flink-Laufzeit zu ändern.

Vor dem Upgrade: Aktualisieren Sie Ihre Apache Flink-Anwendung

Wenn Sie Ihre Flink-Anwendungen schreiben, bündeln Sie sie mit ihren Abhängigkeiten in einer Anwendung JAR und laden sie in Ihren Amazon S3 S3-Bucket hoch. JAR Von dort aus führt Amazon Managed Service für Apache Flink den Job in der neuen Flink-Laufzeit aus, die Sie ausgewählt haben. Möglicherweise müssen Sie Ihre Anwendungen aktualisieren, um die Kompatibilität mit der Flink-Laufzeit zu erreichen, auf die Sie ein Upgrade durchführen möchten. Es kann Inkonsistenzen zwischen den Flink-Versionen geben, die dazu führen, dass das Versionsupgrade fehlschlägt. Am häufigsten wird dies mit Konnektoren für Quellen (Ingress) oder Destinationen (Sinks, Egress) und Scala-Abhängigkeiten geschehen. Flink 1.15 und spätere Versionen in Managed Service for Apache Flink sind Scala-unabhängig, und Sie müssen die Version von Scala enthalten, die Sie JAR verwenden möchten.

Um Ihre Anwendung zu aktualisieren

  1. Lesen Sie die Ratschläge der Flink-Community zur Aktualisierung von Anwendungen mit State. Siehe Aktualisieren von Anwendungen und Flink-Versionen.

  2. Lesen Sie die Liste der bekannten Probleme und Einschränkungen. Siehe Vorsichtsmaßnahmen und bekannte Probleme bei Anwendungsupgrades.

  3. Aktualisieren Sie Ihre Abhängigkeiten und testen Sie Ihre Anwendungen lokal. Diese Abhängigkeiten sind in der Regel:

    1. Die Flink-Laufzeit undAPI.

    2. Für die neue Flink-Laufzeit werden Anschlüsse empfohlen. Sie finden diese unter Release-Versionen für die spezifische Laufzeit, auf die Sie aktualisieren möchten.

    3. Scala — Apache Flink ist ab und einschließlich Flink 1.15 Scala-agnostisch. Sie müssen die Scala-Abhängigkeiten einbeziehen, die Sie in Ihrer Anwendung verwenden möchten. JAR

  4. Erstellen Sie eine neue Anwendung JAR auf einer Zip-Datei und laden Sie sie auf Amazon S3 hoch. Wir empfehlen, dass Sie einen anderen Namen als die vorherige JAR /zip-Datei verwenden. Wenn Sie ein Rollback durchführen müssen, verwenden Sie diese Informationen.

  5. Wenn Sie statusbehaftete Anwendungen ausführen, empfehlen wir Ihnen dringend, einen Snapshot Ihrer aktuellen Anwendung zu erstellen. Auf diese Weise können Sie statusabhängig ein Rollback durchführen, falls während oder nach dem Upgrade Probleme auftreten.