Habilite la reversión del sistema para su aplicación Managed Service for Apache Flink

Con la función de reversión del sistema, puede lograr una mayor disponibilidad de la aplicación Apache Flink en ejecución en Amazon Managed Service for Apache Flink. Al optar por esta configuración, el servicio puede revertir automáticamente la aplicación a la versión que se estaba ejecutando anteriormente cuando una acción, por ejemplo, se produce un error de código UpdateApplication o autoscaling de configuración.

nota

Para utilizar la función de reversión del sistema, debe activarla actualizando la aplicación. De forma predeterminada, las aplicaciones existentes no utilizarán automáticamente la reversión del sistema.

Funcionamiento

Al iniciar una operación de aplicación, como una acción de actualización o escalado, Amazon Managed Service for Apache Flink primero intenta ejecutar esa operación. Si detecta problemas que impiden que la operación se lleve a cabo correctamente, como errores de código o permisos insuficientes, el servicio inicia una operación automáticamente. RollbackApplication

La reversión intenta restaurar la aplicación a la versión anterior que se ejecutó correctamente, junto con el estado de la aplicación asociada. Si la reversión se realiza correctamente, la aplicación seguirá procesando los datos con un tiempo de inactividad mínimo con la versión anterior. Si la reversión automática también falla, Amazon Managed Service for Apache Flink pasa la aplicación al READY estado para que puedas tomar otras medidas, como corregir el error y volver a intentar la operación.

Debe optar por utilizar la reversión automática del sistema. A partir de ahora, puede habilitarlo desde la consola o API para todas las operaciones de la aplicación.

El siguiente ejemplo de solicitud de la UpdateApplication acción permite revertir el sistema de una aplicación:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 1,
   "ApplicationConfigurationUpdate": { 
      "ApplicationSystemRollbackConfigurationUpdate": { 
         "RollbackEnabledUpdate": "true"
       }
    }
}

Revise los escenarios más comunes para la reversión automática del sistema

Los siguientes escenarios ilustran los casos en los que las reversiones automáticas del sistema son beneficiosas:

• Actualizaciones de la aplicación: si actualiza la aplicación con un código nuevo que contiene errores al inicializar la tarea de Flink mediante el método principal, la reversión automática permite restaurar la versión anterior en funcionamiento. Otros escenarios de actualización en los que las reversiones del sistema son útiles incluyen:

  • Si la aplicación se actualiza para que se ejecute con un paralelismo superior a. maxParallelism

  • Si la aplicación se actualiza para que se ejecute con subredes incorrectas para una VPC aplicación, se produce un error durante el inicio del trabajo de Flink.

• Actualizaciones de la versión de Flink: cuando se actualiza a una nueva versión de Apache Flink y la aplicación actualizada detecta un problema de compatibilidad con las instantáneas, la reversión del sistema le permite volver a la versión anterior de Flink automáticamente.

• AutoScaling: Cuando la aplicación se amplía, pero tiene problemas para restaurarse desde un punto de almacenamiento debido a que los operadores no coinciden entre la instantánea y el gráfico de tareas de Flink.

Utilice la operación para revertir el sistema APIs

Para ofrecer una mejor visibilidad, Amazon Managed Service para Apache Flink tiene dos APIs relacionados con las operaciones de las aplicaciones que pueden ayudarle a realizar un seguimiento de los errores y las reversiones del sistema relacionadas.

ListApplicationOperations

Aquí se API enumeran todas las operaciones realizadas en la aplicación, incluidasUpdateApplication,Maintenance, y otrasRollbackApplication, en orden cronológico inverso. En el siguiente ejemplo de solicitud de ListApplicationOperations acción, se enumeran las 10 primeras operaciones de la aplicación:

{
   "ApplicationName": "MyApplication",
   "Limit": 10
}

En el siguiente ejemplo, se solicita ListApplicationOperations ayuda para filtrar la lista para incluir actualizaciones anteriores de la aplicación:

{
   "ApplicationName": "MyApplication",
   "operation": "UpdateApplication"
}

DescribeApplicationOperation

Esto API proporciona información detallada sobre una operación específica enumerada porListApplicationOperations, incluido el motivo del error, si corresponde. En el siguiente ejemplo de solicitud de DescribeApplicationOperation acción, se enumeran los detalles de una operación de aplicación específica:

{
   "ApplicationName": "MyApplication",
   "OperationId": "xyzoperation"
}

Para obtener información sobre la resolución de problemas, consulte Prácticas recomendadas para la reversión del sistema.