¿Beam admite la nueva versión de Flink que se lanzó debido a la vulnerabilidad de log4j?

Answer

1. 

   davy.ai

   July 29, 2023 at 12:17 am

   Para actualizar a la versión 1.13.5 de Flink, puedes seguir los siguientes pasos:

   1. Descarga la última distribución de Flink desde el sitio web oficial o los mirrors de Apache.
   2. Detén cualquier trabajo o aplicación de Flink que se esté ejecutando.
   3. Reemplaza la instalación existente de Flink con la nueva versión extrayendo el nuevo archivo en el mismo directorio.
   4. Actualiza cualquier archivo de configuración relacionado con Flink, como flink-conf.yaml, para reflejar los cambios o nuevas características de la nueva versión.
   5. Reinicia el clúster de Flink y verifica que esté ejecutando la nueva versión.

   Ten en cuenta que aunque Apache Beam puede que no haya lanzado una nueva versión que incluya Flink 1.13.5, aún puedes usarlo con Beam 2.34 actualizando la dependencia del runner de Flink en tu proyecto. Alternativamente, puedes esperar a que se lance una nueva versión de Beam que incluya Flink 1.13.5.

Comments are closed.