Actualice las aplicaciones mediante las actualizaciones de versiones locales de Apache Flink - Managed Service para Apache Flink
Antes de actualizar: actualice su aplicación Apache Flink

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.

Actualice las aplicaciones mediante las actualizaciones de versiones locales de Apache Flink

Antes de empezar, le recomendamos que vea este vídeo: Actualizaciones de versiones locales.

Para realizar actualizaciones locales de las versiones de Apache Flink, puede usar AWS CLI, AWS CloudFormation AWS SDK, o. AWS Management Console Puede utilizar esta función con cualquier aplicación existente que utilice con Managed Service for Apache Flink en un READY estado o estado. RUNNING La utiliza UpdateApplication API para añadir la posibilidad de cambiar el tiempo de ejecución de Flink.

Antes de actualizar: actualice su aplicación Apache Flink

Al escribir las aplicaciones de Flink, las agrupa con sus dependencias en una aplicación JAR y las JAR carga en su bucket de Amazon S3. A partir de ahí, Amazon Managed Service para Apache Flink ejecuta el trabajo en el nuevo entorno de ejecución de Flink que haya seleccionado. Puede que tengas que actualizar tus aplicaciones para lograr la compatibilidad con el entorno de ejecución de Flink al que deseas actualizar. Puede haber incoherencias 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 (sumideros, egresos) y dependencias de Scala. Flink 1.15 y las versiones posteriores de Managed Service for Apache Flink son independientes de Scala y debes incluir la versión de Scala que vayas a JAR usar.

Para actualizar la aplicación

  1. Lea los consejos de la comunidad de Flink sobre cómo actualizar las aplicaciones con el estado. Consulte Actualización de aplicaciones y versiones de Flink.

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

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

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

    2. Se recomiendan conectores para el nuevo entorno de ejecución de Flink. 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 Flink 1.15, inclusive. Debe incluir las dependencias de Scala que desee utilizar en su aplicación. JAR

  4. Cree una nueva aplicación JAR en un archivo zip y cárguela en Amazon S3. Le recomendamos que utilice un nombre diferente al del archivo /zipfile. JAR Si necesita revertirlo, utilizará esta información.

  5. Si ejecuta aplicaciones con estado, le recomendamos encarecidamente que tome una instantánea de la aplicación actual. Esto le permite revertirla de forma automática si tiene problemas durante o después de la actualización.