Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Aggiornamento a Flink 2.2: guida completa

Questa guida fornisce step-by-step istruzioni per aggiornare l'applicazione Amazon Managed Service for Apache Flink da Flink 1.x a Flink 2.2. Si tratta di un aggiornamento di versione importante con modifiche epocali che richiedono un'attenta pianificazione e test.

Prerequisiti

Prima di iniziare l'aggiornamento:

Comprendere i percorsi di migrazione

L'esperienza di aggiornamento dipende dalla compatibilità dell'applicazione con Flink 2.2. La comprensione di questi percorsi aiuta a prepararsi in modo appropriato e a stabilire aspettative realistiche.

Percorso 1: Stato binario e dell'applicazione compatibili

Cosa aspettarsi:

Ideale per: applicazioni stateless o applicazioni che utilizzano serializzazione compatibile (Avro, schemi Protobuf compatibili, senza raccolte) POJOs

Percorso 2: incompatibilità binarie

Cosa aspettarsi:

Ideale per: applicazioni che utilizzano Remove e APIs che vengono rilevate durante l'avvio del job Flink

Percorso 3: Stato dell'applicazione incompatibile

Cosa aspettarsi:

Ideale per: applicazioni con incompatibilità di serializzazione dello stato (con raccolte, determinati stati serializzati POJOs con Kryo)

Fase 1: preparazione

Aggiorna il codice dell'applicazione

Aggiorna il codice dell'applicazione per renderlo compatibile con Flink 2.2:

Carica il codice dell'applicazione aggiornato

Fase 2: abilitare il rollback automatico

Il rollback automatico consente ad Amazon Managed Service for Apache Flink di ripristinare automaticamente la versione precedente se l'aggiornamento non riesce.

Verifica lo stato del rollback automatico

Console di gestione AWS:

AWS CLI:

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

Abilita il rollback automatico (se non abilitato)

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

Fase 3: scattare un'istantanea (opzionale)

Se le istantanee automatiche sono abilitate per l'applicazione, potete saltare questo passaggio, altrimenti scattate un'istantanea dell'applicazione per salvare lo stato dell'applicazione prima dell'aggiornamento.

Scatta un'istantanea dall'applicazione in esecuzione

Console di gestione AWS:

AWS CLI:

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

Verifica la creazione dell'istantanea

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

Attendi fino a quando non SnapshotStatus è così READY prima di procedere.

Fase 4: aggiornamento dell'applicazione

È possibile aggiornare l'applicazione Flink utilizzando l'UpdateApplicationazione.

Puoi chiamare l'UpdateApplicationAPI in diversi modi:

È possibile eseguire l'aggiornamento mentre l'applicazione è in RUNNING stato o mentre l'applicazione è arrestata in READY tale stato. Amazon Managed Service for Apache Flink convalida la compatibilità tra la versione di runtime originale e la versione di runtime di destinazione. Questo controllo di compatibilità viene eseguito quando lo esegui UpdateApplication mentre sei in RUNNING uno stato o successivamente StartApplication se esegui l'upgrade mentre sei in stato. READY

Aggiornamento dallo stato RUNNING

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"
                }
            }
        }
    }'

Aggiornamento dallo stato READY

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"
                }
            }
        }
    }'

Fase 5: aggiornamento del monitor

Verifica della compatibilità

Monitora lo stato delle applicazioni

Stato dell'applicazione:

Inoltre, monitora queste metriche in: CloudWatch

Metrica di riavvio:

Metriche di Checkpoint:

Fase 6: convalida del comportamento dell'applicazione

Dopo l'esecuzione dell'applicazione su Flink 2.2:

Validazione funzionale

Convalida delle prestazioni

Esegui per più di 24 ore

Consenti all'applicazione di funzionare per almeno 24 ore in produzione per garantire:

Fase 7: procedure di rollback

Se l'aggiornamento non riesce o l'applicazione è in esecuzione ma non integra, tornate alla versione precedente.

Rollback automatico

Se il rollback automatico è abilitato e l'aggiornamento non riesce durante l'avvio, Amazon Managed Service for Apache Flink torna automaticamente alla versione precedente.

Rollback manuale

Se l'applicazione è in esecuzione ma non integra, utilizza l'RollbackApplicationAPI:

Console di gestione AWS:

AWS CLI:

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

Cosa succede durante il rollback:

Fasi successive

Per domande o problemi durante l'aggiornamento, consulta Risoluzione dei problemi relativi al servizio gestito per Apache Flink o contatta l' AWS assistenza.