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 step-by-step Anweisungen für das Upgrade Ihrer Amazon Managed Service for Apache Flink-Anwendung von Flink 1.x auf Flink 2.2. Dies ist ein Hauptversions-Upgrade mit grundlegenden Änderungen, die sorgfältige Planung und Tests erfordern.

Voraussetzungen

Bevor Sie mit dem Upgrade beginnen:

Verstehen Sie Ihre Migrationspfade

Ihr Upgrade-Erlebnis 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 setzen.

Pfad 1: Kompatibler Binär- und Anwendungsstatus

Was ist zu erwarten:

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

Pfad 2: Binäre Inkompatibilitäten

Was ist zu erwarten:

Ideal für: Anwendungen APIs , die entfernte Anwendungen verwenden und beim Start des Flink-Jobs erkannt wurden

Pfad 3: Status der inkompatiblen Anwendung

Was ist zu erwarten:

Am besten geeignet für: Anwendungen mit Inkompatibilitäten bei der staatlichen Serialisierung (POJOs mit Sammlungen, bestimmter Status mit Kryo-Serialisierung)

Phase 1: Vorbereitung

Aktualisieren Sie den Anwendungscode

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

Laden Sie den aktualisierten Anwendungscode hoch

Phase 2: Automatisches Rollback aktivieren

Mit Auto-Rollback kann Amazon Managed Service für Apache Flink automatisch zur vorherigen Version zurückkehren, falls 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'

Automatisches Rollback aktivieren (falls nicht aktiviert)

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

Phase 3: Schnappschuss 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.

Machen 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 Erstellung des Snapshots

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 UpdateApplicationAktion 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 für Apache Flink überprüft die Kompatibilität zwischen der ursprünglichen Runtime-Version und der Ziel-Runtime-Version. Diese Kompatibilitätsprüfung wird ausgeführt, wenn Sie diese durchführen, UpdateApplication während Sie sich im RUNNING Status befinden, oder beim nächsten Mal, StartApplication wenn Sie ein Upgrade durchführen, während Sie sich im READY Status befinden.

Führen Sie das Upgrade vom Status RUNNING aus

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 ein 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: Überwachen Sie das Upgrade

Kompatibilitätsprüfung

Überwachen Sie den Zustand der Anwendung

Status der Anwendung:

Überwachen Sie außerdem diese Metriken in CloudWatch:

Metrik neu starten:

Checkpoint-Metriken:

Phase 6: Überprüfen Sie das Anwendungsverhalten

Nachdem die Anwendung auf Flink 2.2 ausgeführt wurde:

Funktionale Validierung

Überprüfung der Leistung

Läuft für mehr als 24 Stunden

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

Phase 7: Rollback-Verfahren

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

Automatisches Rollback

Wenn Auto-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 während des Upgrades wenden Sie sich an den Support Fehlerbehebung bei Managed Service für Apache Flink oder wenden Sie sich an den AWS Support.