Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Mise à niveau vers Flink 2.2 : guide complet

Ce guide fournit des step-by-step instructions pour mettre à niveau votre application Amazon Managed Service for Apache Flink de Flink 1.x vers Flink 2.2. Il s'agit d'une mise à niveau majeure avec des modifications importantes qui nécessitent une planification et des tests minutieux.

Conditions préalables

Avant de commencer votre mise à niveau :

Comprendre vos parcours de migration

Votre expérience de mise à niveau dépend de la compatibilité de votre application avec Flink 2.2. La compréhension de ces parcours vous aide à vous préparer de manière appropriée et à définir des attentes réalistes.

Chemin 1 : Binaire compatible et état de l'application

À quoi s'attendre :

Idéal pour : les applications apatrides ou les applications utilisant une sérialisation compatible (Avro, schémas Protobuf compatibles, sans collections) POJOs

Voie 2 : Incompatibilités binaires

À quoi s'attendre :

Idéal pour : les applications utilisant des applications supprimées APIs détectées lors du démarrage d'une tâche Flink

Chemin 3 : État de l'application incompatible

À quoi s'attendre :

Idéal pour : les applications présentant des incompatibilités de sérialisation d'états (POJOs avec des collections, certains états sérialisés en Kryo)

Phase 1 : Préparation

Mettre à jour le code d'application

Mettez à jour le code de votre application pour qu'il soit compatible avec Flink 2.2 :

Téléchargez le code d'application mis à jour

Phase 2 : activer la restauration automatique

La restauration automatique permet à Amazon Managed Service pour Apache Flink de revenir automatiquement à la version précédente en cas d'échec de la mise à niveau.

Vérifier l'état de la restauration automatique

AWS Management Console:

AWS CLI:

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

Activer la restauration automatique (si elle n'est pas activée)

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

Phase 3 : Prendre un instantané (facultatif)

Si les instantanés automatiques sont activés pour votre application, vous pouvez ignorer cette étape. Sinon, prenez un instantané de votre application pour enregistrer son état avant de procéder à la mise à niveau.

Prendre un instantané depuis une application en cours d'exécution

AWS Management Console:

AWS CLI:

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

Vérifier la création de snapshots

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

Attendez jusqu'à ce que ce SnapshotStatus soit READY le cas avant de continuer.

Phase 4 : mise à niveau de l'application

Vous pouvez mettre à niveau votre application Flink à l'aide de cette UpdateApplicationaction.

Vous pouvez appeler l'UpdateApplicationAPI de différentes manières :

Vous pouvez effectuer la mise à niveau pendant que l'application est en RUNNING état ou pendant que l'application est arrêtée. READY Amazon Managed Service pour Apache Flink valide la compatibilité entre la version d'exécution d'origine et la version d'exécution cible. Ce contrôle de compatibilité s'exécute lorsque vous effectuez une mise à niveau UpdateApplication alors que vous êtes dans RUNNING l'état ou le suivant StartApplication si vous effectuez une mise à niveau alors que vous êtes dans READY l'état.

Mise à niveau depuis l'état 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"
                }
            }
        }
    }'

Mise à niveau depuis l'état PRÊT

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 : mise à niveau du moniteur

Contrôle de compatibilité

Surveiller l'état des applications

État de l'application :

En outre, surveillez ces indicateurs dans CloudWatch :

Métrique de redémarrage :

Mesures relatives aux points de contrôle :

Phase 6 : Valider le comportement de l'application

Après l'exécution de l'application sur Flink 2.2 :

Validation fonctionnelle

Validation des performances

Courez pendant plus de 24 heures

Permettez à l'application de fonctionner pendant au moins 24 heures en production afin de garantir :

Phase 7 : Procédures de rétrogradation

Si la mise à niveau échoue ou si l'application est en cours d'exécution mais ne fonctionne pas correctement, revenez à la version précédente.

Annulation automatique

Si la restauration automatique est activée et que la mise à niveau échoue au démarrage, Amazon Managed Service pour Apache Flink revient automatiquement à la version précédente.

Annulation manuelle

Si l'application est en cours d'exécution mais ne fonctionne pas correctement, utilisez l'RollbackApplicationAPI :

AWS Management Console:

AWS CLI:

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

Que se passe-t-il lors du rollback :

Étapes suivantes

Pour toute question ou problème lors de la mise à niveau, consultez le Support Résoudre les problèmes liés au service géré pour Apache Flink ou contactez le AWS Support.