Mettez à niveau les applications à l'aide de mises à niveau de version sur place pour Apache Flink - Service géré pour Apache Flink
Avant la mise à niveau : mettez à jour votre application Apache Flink

Le service géré Amazon pour Apache Flink était auparavant connu sous le nom d’Amazon Kinesis Data Analytics pour Apache Flink.

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.

Mettez à niveau les applications à l'aide de mises à niveau de version sur place pour Apache Flink

Avant de commencer, nous vous recommandons de regarder cette vidéo : Mises à niveau des versions sur place.

Pour effectuer des mises à niveau de version sur place pour Apache Flink, vous pouvez utiliser le AWS CLI, AWS CloudFormation AWS SDK, ou le. AWS Management Console Vous pouvez utiliser cette fonctionnalité avec toutes les applications existantes que vous utilisez avec le service géré pour Apache Flink à RUNNING l'état READY or. Il utilise le UpdateApplication API pour ajouter la possibilité de modifier le runtime de Flink.

Avant la mise à niveau : mettez à jour votre application Apache Flink

Lorsque vous écrivez vos applications Flink, vous les regroupez avec leurs dépendances dans une application JAR et vous les JAR téléchargez dans votre compartiment Amazon S3. À partir de là, Amazon Managed Service pour Apache Flink exécute la tâche dans le nouveau moteur d'exécution Flink que vous avez sélectionné. Vous devrez peut-être mettre à jour vos applications pour assurer la compatibilité avec le moteur d'exécution Flink vers lequel vous souhaitez effectuer la mise à niveau. Des incohérences entre les versions de Flink peuvent entraîner l'échec de la mise à niveau de la version. Le plus souvent, cela se fera avec des connecteurs pour les sources (entrée) ou les destinations (récepteurs, sorties) et les dépendances Scala. Les versions 1.15 et ultérieures de Managed Service for Apache Flink sont indépendantes de Scala et vous JAR devez contenir la version de Scala que vous prévoyez d'utiliser.

Pour mettre à jour votre application

  1. Lisez les conseils de la communauté Flink sur la mise à niveau des applications avec State. Consultez la section Mise à niveau des applications et des versions de Flink.

  2. Consultez la liste des problèmes et des limites connus. Consultez Précautions et problèmes connus liés aux mises à niveau des applications.

  3. Mettez à jour vos dépendances et testez vos applications localement. Ces dépendances sont généralement les suivantes :

    1. Le runtime Flink et. API

    2. Connecteurs recommandés pour le nouveau moteur d'exécution de Flink. Vous pouvez les trouver dans les versions Release du moteur d'exécution spécifique vers lequel vous souhaitez effectuer la mise à jour.

    3. Scala — Apache Flink est indépendant de Scala à partir de Flink 1.15 inclus. Vous devez inclure les dépendances Scala que vous souhaitez utiliser dans votre applicationJAR.

  4. Créez une nouvelle application JAR sur un fichier zip et chargez-la sur Amazon S3. Nous vous recommandons d'utiliser un nom différent de celui du précédent JAR /zipfile. Si vous devez revenir en arrière, vous utiliserez ces informations.

  5. Si vous exécutez des applications dynamiques, nous vous recommandons vivement de prendre un instantané de votre application actuelle. Cela vous permet de revenir en arrière de manière dynamique si vous rencontrez des problèmes pendant ou après la mise à niveau.