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 istruzioni dettagliate per aggiornare l'applicazione Amazon Managed Service for Apache Flink da Flink 1.x a Flink 2.2. Si tratta di un importante aggiornamento della versione con modifiche sostanziali 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 vi aiuta a prepararvi in modo appropriato e a stabilire aspettative realistiche.

Percorso 1: binario compatibile e stato dell'applicazione

Cosa aspettarsi:

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

Percorso 2: incompatibilità binarie

Cosa aspettarsi:

Ideale per: applicazioni che utilizzano API rimosse rilevate durante l'avvio del processo di Flink

Percorso 3: Stato dell'applicazione non compatibile

Cosa aspettarsi:

Ideale per: applicazioni con incompatibilità di serializzazione a livello di stato (POJO con raccolte, determinati stati) Kryo-serialized

Fase 1: preparazione

Aggiornamento del 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

Auto-rollback consente ad Amazon Managed Service for Apache Flink di tornare automaticamente alla 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: Scatta un'istantanea (opzionale)

Se le istantanee automatiche sono abilitate per la tua applicazione, puoi saltare questo passaggio, altrimenti scatta un'istantanea dell'applicazione per salvarne lo stato 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 che SnapshotStatus sia pronto 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 è interrotta. READY 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 esegui l'operazione UpdateApplication mentre sei nello RUNNING stato o alla successiva StartApplication se esegui l'aggiornamento mentre sei nello 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 dei checkpoint:

Fase 6: convalida del comportamento dell'applicazione

Dopo che l'applicazione è in esecuzione su Flink 2.2:

Convalida funzionale

Convalida delle prestazioni

Funziona 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, ripristina la 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'assistenza. AWS