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.

Upgrade auf Flink 2.2: Vollständige Anleitung

Dieses Handbuch enthält schrittweise Anweisungen zum Upgrade Ihrer Amazon Managed Service for Apache Flink-Anwendung von Flink 1.x auf Flink 2.2. Dies ist ein Hauptversions-Upgrade mit wichtigen Änderungen, die eine sorgfältige Planung und Prüfung erfordern.

Voraussetzungen

Bevor Sie mit dem Upgrade beginnen:

Verstehen Sie Ihre Migrationspfade

Ihre Upgrade-Erfahrung hängt von der Kompatibilität Ihrer Anwendung mit Flink 2.2 ab. Wenn Sie diese Pfade kennen, können Sie sich angemessen vorbereiten und realistische Erwartungen stellen.

Pfad 1: Kompatibler Binär- und Anwendungsstatus

Was ist zu erwarten:

Ideal für: Zustandslose Anwendungen oder Anwendungen mit kompatibler Serialisierung (Avro, kompatible Protobuf-Schemas, POJOs ohne Sammlungen)

Pfad 2: Binäre Inkompatibilitäten

Was ist zu erwarten:

Am besten geeignet für: Anwendungen, die entfernte APIs verwenden und die beim Start des Flink-Jobs erkannt werden

Pfad 3: Inkompatibler Anwendungsstatus

Was ist zu erwarten:

Ideal für: Anwendungen mit Inkompatibilitäten bei der Serialisierung von Bundesstaaten (POJOs mit Sammlungen, bestimmter Status) Kryo-serialized

Phase 1: Vorbereitung

Anwendungscode aktualisieren

Aktualisieren Sie Ihren Anwendungscode, damit er mit Flink 2.2 kompatibel ist:

Laden Sie den aktualisierten Anwendungscode hoch

Phase 2: Automatisches Rollback aktivieren

Auto-rollback ermöglicht Amazon Managed Service für Apache Flink, automatisch zur vorherigen Version zurückzukehren, wenn das Upgrade fehlschlägt.

Überprüfen Sie den Status des automatischen Rollbacks

AWS-Managementkonsole:

AWS CLI:

aws kinesisanalyticsv2 describe-application \
    --application-name MyApplication \
    --query 'ApplicationDetail.ApplicationConfigurationDescription.ApplicationSystemRollbackConfigurationDescription.RollbackEnabled'

Aktivieren Sie das automatische Rollback (falls nicht aktiviert)

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --application-configuration-update '{
        "ApplicationSystemRollbackConfigurationUpdate": {
            "RollbackEnabledUpdate": true
        }
    }'

Phase 3: Snapshot erstellen (optional)

Wenn automatische Snapshots für Ihre Anwendung aktiviert sind, können Sie diesen Schritt überspringen. Andernfalls erstellen Sie vor dem Upgrade einen Snapshot Ihrer Anwendung, um den Status Ihrer Anwendung zu speichern.

Erstellen Sie einen Snapshot von der laufenden Anwendung

AWS-Managementkonsole:

AWS CLI:

aws kinesisanalyticsv2 create-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

Überprüfen Sie die Snapshot-Erstellung

aws kinesisanalyticsv2 describe-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

Warten Sie, bis dies SnapshotStatus der Fall ist, READY bevor Sie fortfahren.

Phase 4: Anwendung aktualisieren

Sie können Ihre Flink-Anwendung aktualisieren, indem Sie die UpdateApplication Aktion verwenden.

Sie können die UpdateApplication API auf verschiedene Arten aufrufen:

Sie können das Upgrade durchführen, während sich die Anwendung im RUNNING Status befindet oder während die Anwendung im READY Status gestoppt ist. Amazon Managed Service for Apache Flink validiert die Kompatibilität zwischen der ursprünglichen Laufzeitversion und der Ziel-Laufzeitversion. Diese Kompatibilitätsprüfung wird ausgeführt, wenn Sie im RUNNING Status sind, oder beim nächsten Mal, StartApplication wenn Sie während des Status ein Upgrade durchführen. UpdateApplication READY

Führen Sie das Upgrade im Status RUNNING durch

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

Führen Sie das Upgrade aus dem Status BEREIT durch

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

Phase 5: Aktualisierung des Monitors

Kompatibilitätsprüfung

Überwachen Sie den Zustand der Anwendung

Status der Anwendung:

Überwachen Sie diese Metriken außerdem in CloudWatch:

Metrik neu starten:

Checkpoint-Metriken:

Phase 6: Überprüfen Sie das Anwendungsverhalten

Nachdem die Anwendung auf Flink 2.2 ausgeführt wird:

Funktionale Validierung

Überprüfung der Leistung

Mehr als 24 Stunden laufen lassen

Lassen Sie die Anwendung in der Produktion mindestens 24 Stunden lang laufen, um Folgendes sicherzustellen:

Phase 7: Rollback-Verfahren

Wenn das Upgrade fehlschlägt oder die Anwendung zwar läuft, aber fehlerhaft ist, führen Sie ein Rollback zur vorherigen Version durch.

Automatisches Rollback

Wenn das automatische Rollback aktiviert ist und das Upgrade beim Start fehlschlägt, kehrt Amazon Managed Service für Apache Flink automatisch zur vorherigen Version zurück.

Manuelles Rollback

Wenn die Anwendung läuft, aber fehlerhaft ist, verwenden Sie die RollbackApplication API:

AWS-Managementkonsole:

AWS CLI:

aws kinesisanalyticsv2 rollback-application \
    --application-name MyApplication \
    --current-application-version-id <version-id>

Was passiert beim Rollback:

Nächste Schritte

Bei Fragen oder Problemen beim Upgrade wenden Sie sich an den Support Fehlerbehebung bei Managed Service für Apache Flink oder wenden Sie sich an den AWS Support.