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 instructions détaillées pour mettre à niveau votre application Amazon Managed Service pour Apache Flink de Flink 1.x à Flink 2.2. Il s'agit d'une mise à niveau majeure de la version avec des modifications majeures 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 trajectoires vous aide à vous préparer de manière appropriée et à définir des attentes réalistes.

Chemin 1 : état du binaire et de l'application compatibles

À quoi s'attendre :

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

Voie 2 : Incompatibilités binaires

À quoi s'attendre :

Idéal pour : les applications utilisant des API supprimées détectées lors du démarrage de la 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 (POJO avec collections, certains états) Kryo-serialized

Phase 1 : Préparation

Mettre à jour le code d'application

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

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

Phase 2 : activer la restauration automatique

Auto-rollback 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 restauration automatique

Console de gestion AWS:

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 l'état de votre application avant la mise à niveau.

Prendre un instantané de l'application en cours d'exécution

Console de gestion AWS:

AWS CLI:

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

Vérifier la création d'un instantané

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 en utilisant cette UpdateApplication action.

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

Vous pouvez effectuer la mise à niveau pendant que l'application est RUNNING en cours d'exécution ou lorsque l'application est READY arrêtée. 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 en RUNNING état ou à la suivante StartApplication si vous effectuez une mise à niveau alors qu'il est en READY état.

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

Phase 5 : mise à niveau du moniteur

Contrôle de compatibilité

Surveiller l'état des applications

État de la demande :

En outre, surveillez ces indicateurs dans les domaines CloudWatch suivants :

Métrique de redémarrage :

Métriques des points de contrôle :

Phase 6 : Valider le comportement de l'application

Une fois l'application exécutée sur Flink 2.2 :

Validation fonctionnelle

Validation des performances

Courez pendant plus de 24 heures

Autorisez l'application à s'exécuter pendant au moins 24 heures en production pour garantir :

Phase 7 : Procédures de restauration

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 qu'elle ne fonctionne pas correctement, utilisez l'RollbackApplicationAPI :

Console de gestion AWS:

AWS CLI:

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

Que se passe-t-il lors de la restauration :

Étapes suivantes

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