Actualización de aplicaciones mediante actualizaciones de las versiones in situ para Apache Flink - Managed Service para Apache Flink
Antes de actualización: actualice la aplicación Apache Flink

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

Actualización de aplicaciones mediante actualizaciones de las versiones in situ para Apache Flink

Antes de comenzar, se recomienda que vea este video: In-Place Version Upgrades.

Para actualizar las versiones locales de Apache Flink, puede usar la AWS CLIAWS CloudFormation, AWS SDK o la Consola de administración de AWS. Se puede utilizar esta función con cualquier aplicación existente que se utilice con Managed Service para Apache Flink en un estado READY o estado .RUNNING Utiliza la API de UpdateApplication para añadir la posibilidad de cambiar el tiempo de ejecución de Flink.

Antes de actualización: actualice la aplicación Apache Flink

Al escribir las aplicaciones de Flink, las agrupa con sus dependencias en una JAR de aplicaciones y carga la JAR en su bucket de Amazon S3. A partir de ahí, Amazon Managed Service para Apache Flink ejecuta el trabajo en el nuevo tiempo de ejecución de Flink que haya seleccionado. Quizá se deban actualizar las aplicaciones para lograr la compatibilidad con el entorno de ejecución de Flink al que desea actualizar. Se puede haber inconsistencias entre las versiones de Flink que provoquen un error en la actualización de la versión. Lo más habitual es que se utilice con conectores para fuentes (entrada) o destinos (receptores, egresos) y dependencias de Scala. Flink 1.15 y las versiones posteriores de Managed Service para Apache Flink son independientes de Scala, y su JAR debe contener la versión de Scala que planea usar.

Cómo actualizar su aplicación

  1. Lea los consejos en la comunidad de Flink sobre cómo actualizar las aplicaciones con el estado. Consulte Upgrading Applications and Flink Versions.

  2. Lea la lista de problemas y limitaciones conocidos. Consulte Precauciones y problemas conocidos relacionados con actualizaciones de aplicaciones.

  3. Actualice sus dependencias y pruebe sus aplicaciones localmente. Estas dependencias suelen ser:

    1. El tiempo de ejecución y la API de Flink.

    2. Se recomiendan conectores para el nuevo tiempo de ejecución de Flink. Se puede encontrarlos en las versiones de lanzamiento correspondientes al tiempo de ejecución específico al que desee actualizar.

    3. Scala: Apache Flink es independiente de Scala a partir de la versión 1.15 de Flink, incluida esta versión. Debe incluir las dependencias de Scala que desee utilizar en la JAR de la aplicación.

  4. Cree una JAR de aplicación en un archivo zip y cárguelo en Amazon S3. Se recomienda que utilice un nombre diferente de la jar/zip anterior. Si necesita realizar una reversión, utilizará esta información.

  5. Si se ejecutan aplicaciones con estado, se recomienda que tome una instantánea de la aplicación actual. Esto permite revertirla de forma automática si surgen problemas durante o después de la actualización.