Exécuter un service géré pour l'application Apache Flink - Service géré pour Apache Flink
Identifier la candidature et le statut du posteExécuter des charges de travail par lots

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.

Exécuter un service géré pour l'application Apache Flink

Cette rubrique contient des informations sur l’exécution d’un service géré pour Apache Flink.

Lorsque vous exécutez votre application de service géré pour Apache Flink, le service crée une tâche Apache Flink. Une tâche Apache Flink correspond au cycle de vie d’exécution de votre application de service géré pour Apache Flink. L’exécution de la tâche et les ressources qu’elle utilise sont gérées par le gestionnaire de tâches. Le gestionnaire de tâches divise l’exécution de l’application en tâches. Chaque tâche est gérée par un gestionnaire de tâches. Lorsque vous surveillez les performances de votre application, vous pouvez examiner les performances de chaque gestionnaire de tâches ou du gestionnaire de tâches global.

Pour plus d'informations sur les tâches Apache Flink, consultez la section Tâches et planification dans la documentation d'Apache Flink.

Identifier la candidature et le statut du poste

Votre application et la tâche de l’application ont tous deux un état d’exécution actuel :

  • État de l’application : l’état actuel de votre application décrit sa phase d’exécution. Les états de l’application sont les suivants :

    • États d’application stables : votre application conserve généralement ces états jusqu’à ce que vous modifiiez son état :

      • READY: le READY statut d'une application nouvelle ou arrêtée est conservé jusqu'à ce que vous l'exécutiez.

      • RUNNING: le RUNNING statut d'une application qui a été démarrée avec succès est en cours.

    • États d’application transitoires : une application présentant ces états est généralement en train de passer à un autre état. Si une application reste dans un état transitoire pendant un certain temps, vous pouvez arrêter l'application à l'aide de l'StopApplicationaction dont le Force paramètre est défini sur. true Ces états incluent les éléments suivants :

      • STARTING:Survient après l'StartApplicationaction. L’application est en train de passer de l’état READY à l’état RUNNING.

      • STOPPING:Survient après l'StopApplicationaction. L’application est en train de passer de l’état RUNNING à l’état READY.

      • DELETING:Survient après l'DeleteApplicationaction. L’application est en cours de suppression.

      • UPDATING:Survient après l'UpdateApplicationaction. L’application est en cours de mise à jour et va revenir à l’état RUNNING ou READY.

      • AUTOSCALING:L'application possède la AutoScalingEnabled propriété ParallelismConfigurationset totrue, et le service augmente le parallélisme de l'application. Lorsque l'application est dans cet état, la seule API action valide que vous pouvez utiliser est celle StopApplicationdont le Force paramètre est défini surtrue. Pour obtenir des informations sur la mise à l’échelle automatique, consultez Utiliser le dimensionnement automatique dans Managed Service pour Apache Flink.

      • FORCE_STOPPING:Survient après l'appel de l'StopApplicationaction avec le Force paramètre défini surtrue. Un arrêt forcé de l’application est en cours. L’application est en train de passer de l’état STARTING, UPDATING, STOPPING, ou AUTOSCALING à l’état READY.

      • ROLLING_BACK:Survient après l'appel de RollbackApplicationl'action. L’application est en train de revenir à une version précédente. L’application est en train de passer de l’état UPDATING ou AUTOSCALING à l’état RUNNING.

      • MAINTENANCE: survient lorsque le service géré pour Apache Flink applique des correctifs à votre application. Pour de plus amples informations, veuillez consulter Gestion des tâches de maintenance pour le service géré pour Apache Flink.

    Vous pouvez vérifier l'état de votre application à l'aide de la console ou à l'aide de l'DescribeApplicationaction.

  • État de la tâche : lorsque votre application est à l’état RUNNING, votre tâche a un état qui décrit sa phase d’exécution en cours. Une tâche commence avec le statut CREATED, puis passe à l’état RUNNING une fois qu’elle a démarré. En cas d’erreur, votre application passe au statut suivant :

    • Pour les applications utilisant Apache Flink 1.11 et versions ultérieures, votre application entre dans l’état RESTARTING.

    • Pour les applications utilisant Apache Flink 1.8 et versions antérieures, votre application entre dans l’état FAILING.

    L’application passe ensuite à l’état RESTARTING ou FAILED, selon que la tâche peut être redémarrée ou non.

    Vous pouvez vérifier le statut du poste en consultant le CloudWatch journal de votre candidature pour vérifier les changements de statut.

Exécuter des charges de travail par lots

Le service géré Apache Flink prend en charge l’exécution de charges de travail par lots Apache Flink. Dans un traitement par lots, lorsqu'un travail Apache Flink atteint le FINISHEDstatut, le statut de l'application Managed Service for Apache Flink est défini sur. READY Pour plus d’informations sur les états des tâches Flink, consultez la section Jobs and Scheduling.