Prácticas recomendadas y sugerencias generales para actualizaciones de aplicaciones - Managed Service para Apache Flink

Amazon Managed Service para Apache Flink Amazon (Amazon MSF) 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.

Prácticas recomendadas y sugerencias generales para actualizaciones de aplicaciones

  • Pruebe el nuevo trabajo/tiempo de ejecución sin estado en un entorno de no producción antes de intentar realizar una actualización de producción.

  • Primero puede probar la actualización con estado con una aplicación que no sea de producción.

  • Asegúrese de que el nuevo gráfico de tareas tenga un estado compatible con la instantánea que se usará para iniciar la aplicación actualizada.

    • Asegúrese de que los tipos almacenados en los estados del operador permanezcan iguales. Si el tipo ha cambiado, Apache Flink no podrá restaurar el estado del operador.

    • Asegúrese de que los ID de operador que configuró con el método uid sigan siendo los mismos. Apache Flink recomienda asignar identificadores únicos a los operadores. Para obtener más información, consulte Assigning Operator IDs en la documentación de Apache Flink.

      Si no se asignan ID a sus operadores, Flink los genera automáticamente. En ese caso, pueden depender de la estructura del programa y, si se modifican, pueden provocar problemas de compatibilidad. Flink usa los ID de operador para coincidir el estado de la instantánea con el operador. Al cambiar los ID de operador, la aplicación no se inicia o se elimina el estado almacenado en la instantánea y el nuevo operador se inicia sin estado.

    • No cambie la clave utilizada para almacenar el estado de la clave.

    • No modifique el tipo de entrada de los operadores con estado, como window o join. Hacerlo cambia implícitamente el tipo de estado interno del operador y provoca una incompatibilidad de estados.