Ejecución de una aplicación de Managed Service para Apache Flink - Managed Service para Apache Flink
Identificación del estado del trabajo y de la aplicaciónEjecución de cargas de trabajo en lotes

Amazon Managed Service para Apache Flink Amazon (Amazon MSF) se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.

Ejecución de una aplicación de Managed Service para Apache Flink

En este tema, se incluye información acerca de cómo ejecutar una aplicación de Managed Service para Apache Flink.

Al ejecutar la aplicación de Managed Service para Apache Flink, el servicio crea un trabajo de Apache Flink. Un trabajo de Apache Flink es el ciclo de vida de ejecución de la aplicación de Managed Service para Apache Flink. El administrador de trabajos administra la ejecución del trabajo y los recursos que utiliza. El administrador de trabajos divide la ejecución de la aplicación en tareas. Cada tarea es gestionada por un administrador de tareas. Al supervisar el rendimiento de la aplicación, se puede examinar el rendimiento de cada administrador de tareas o del administrador de trabajos en su conjunto.

Para obtener más información sobre trabajos en Apache Flink, consulte Job and Scheduling en la documentación de Apache Flink.

Identificación del estado del trabajo y de la aplicación

Tanto su solicitud como el trabajo de la solicitud tienen un estado de ejecución actual:

  • Estado de la solicitud: su solicitud tiene un estado actual que describe su fase de ejecución. El estado de la aplicación puede ser cualquiera de los siguientes:

    • Estado de solicitud estable: la solicitud normalmente permanece en este estado hasta que se realiza un cambio de estado:

      • LISTA: una aplicación nueva o detenida se encuentra LISTA hasta que se la ejecuta.

      • EN EJECUCIÓN: una aplicación que se ha iniciado correctamente se encuentra EN EJECUCIÓN.

    • Estado de aplicación transitorio: una aplicación en este estado suele estar en proceso de transición a otro estado. Si la aplicación permanece en un estado transitorio por mucho tiempo, puede detenerla mediante la acción StopApplication con el parámetro Force establecido en true. Este estado incluye los siguientes:

      • STARTING: se produce después de la acción StartApplication. La aplicación está pasando del estado READY al RUNNING.

      • STOPPING: se produce después de la acción StopApplication. La aplicación está pasando del estado RUNNING al READY.

      • DELETING: se produce después de la acción DeleteApplication. La aplicación está en proceso de ser eliminada.

      • UPDATING: se produce después de la acción UpdateApplication. La aplicación se está actualizando y volverá al estado RUNNING o READY.

      • AUTOSCALING: la aplicación tiene la propiedad AutoScalingEnabled de ParallelismConfiguration establecida en true y el servicio aumenta el paralelismo de la aplicación. Cuando la aplicación se encuentra en este estado, la única acción de API válida que se puede usar es la acción StopApplication con el parámetro Force establecido en true. Para obtener información sobre el escalado automático, consulte Uso del escalado automático en Managed Service para Apache Flink.

      • FORCE_STOPPING: se produce después de solicitar la acción StopApplication con el parámetro Force establecido en true. La aplicación está en proceso de ser detenida forzosamente. La aplicación está pasando del estado STARTING, UPDATING, STOPPING o AUTOSCALING al READY.

      • ROLLING_BACK: se produce después de solicitar la acción RollbackApplication. La aplicación está en proceso de revertirse a una versión anterior. La aplicación está pasando del estado UPDATING o AUTOSCALING al RUNNING.

      • MAINTENANCE: se produce mientras Managed Service para Apache Flink aplica parches a la aplicación. Para obtener más información, consulte Administración de las tareas de mantenimiento de Managed Service para Apache Flink.

    Puede comprobar el estado de la aplicación mediante la consola o mediante la acción DescribeApplication.

  • Estado del trabajo: cuando la solicitud está en el estado RUNNING, el trabajo tiene un estado que describe su fase de ejecución actual. El trabajo comienza en el estado CREATEDy, a continuación, pasa al estado RUNNING cuando se inicia. Si se producen condiciones de error, la aplicación pasa al siguiente estado:

    • En el caso de las aplicaciones que utilizan Apache Flink 1.11 y versiones posteriores, la aplicación ingresa al estado RESTARTING.

    • En el caso de las aplicaciones que utilizan Apache Flink 1.8 y versiones anteriores, la aplicación ingresa al estado FAILING.

    A continuación, la aplicación pasa al estado RESTARTING o FAILED, en función de si se puede reiniciar el trabajo.

    Para comprobar el estado del trabajo, verifique el registro de CloudWatch de la aplicación para ver si hubo cambios de estado.

Ejecución de cargas de trabajo en lotes

Managed Service para Apache Flink admite la ejecución de cargas de trabajo por lotes de Apache Flink. En un trabajo por lotes, cuando un trabajo de Apache Flink pasa al estado FINALIZADO, el estado de la aplicación de Managed Service para Apache Flink se establece en LISTO. Para obtener más información sobre el estado de los trabajos de Flink, consulte Job Scheduling.