Ejecute un servicio gestionado para la aplicación Apache Flink - Managed Service para Apache Flink
Identifique el estado de la solicitud y del puestoEjecute cargas de trabajo por lotes

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

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Ejecute un servicio gestionado para la aplicación 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 información sobre los trabajos de Apache Flink, consulte Trabajos y programación en la documentación de Apache Flink.

Identifique el estado de la solicitud y del puesto

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:

      • READY: Una solicitud nueva o detenida está en ese READY estado hasta que la ejecute.

      • RUNNING: una aplicación que se ha iniciado correctamente se encuentra en ese RUNNING estado.

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

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

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

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

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

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

      • FORCE_STOPPING:Se produce después de llamar a la StopApplicationacción con el Force parámetro establecido entrue. 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 llamar a la RollbackApplicationacción. 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 Gestione las tareas de mantenimiento de Managed Service for Apache Flink.

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

  • 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.

    Puedes comprobar el estado del trabajo examinando el CloudWatch registro de tu solicitud para ver si hay cambios de estado.

Ejecute cargas de trabajo por 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 alcanza el FINISHEDestado, el estado de la aplicación Managed Service for Apache Flink se establece en. READY Para obtener más información sobre el estado de los trabajos de Flink, consulte Job Scheduling.