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 Studio Runtime
Esta sección contiene información sobre cómo actualizar el entorno de ejecución de tu portátil Studio. Te recomendamos que siempre actualices a la última versión de Studio Runtime compatible.
Actualice su portátil a un nuevo Studio Runtime
Según cómo utilices Studio, los pasos para actualizar tu Runtime varían. Selecciona la opción que mejor se adapte a tu caso de uso.
Si utiliza SQL Python sin dependencias externas, utilice el siguiente proceso de actualización en tiempo de ejecución. Le recomendamos que actualice a la última versión de Runtime. El proceso de actualización es el mismo, independientemente de la versión de Runtime desde la que se esté actualizando.
-
Crea un nuevo bloc de notas de Studio con la última versión de Runtime.
-
Copia y pega el código de cada nota de la libreta antigua a la nueva.
-
En la nueva libreta, ajusta el código para que sea compatible con cualquier función de Apache Flink que haya cambiado con respecto a la versión anterior.
-
Ejecute el nuevo bloc de notas. Abre el cuaderno y ejecútalo nota por nota, en secuencia, y comprueba si funciona.
-
Realice los cambios necesarios en el código.
-
Detenga la nueva libreta.
-
-
Si hubiera implementado el portátil antiguo como aplicación:
-
Implemente el nuevo portátil como una aplicación nueva e independiente.
-
Detenga la aplicación anterior.
-
Ejecute la nueva aplicación sin la instantánea.
-
-
Detenga el portátil antiguo si está funcionando. Inicie el nuevo bloc de notas, según sea necesario, para un uso interactivo.
Flujo del proceso de actualización sin dependencias externas
Siga este proceso si utiliza Python y utiliza SQL dependencias externas, como conectores o artefactos personalizados, como funciones definidas por el usuario implementadas en Python o Java. Le recomendamos que actualice a la última versión de Runtime. El proceso es el mismo, independientemente de la versión de Runtime desde la que se esté actualizando.
-
Cree un nuevo bloc de notas de Studio con la última versión de Runtime.
-
Copia y pega el código de cada nota de la libreta antigua a la nueva.
-
Actualiza las dependencias externas y los artefactos personalizados.
-
Busque nuevos conectores compatibles con la versión Apache Flink del nuevo Runtime. Consulte Tabla y SQL conectores
en la documentación de Apache Flink para encontrar los conectores correctos para la versión de Flink. -
Actualice el código de las funciones definidas por el usuario para que coincida con los cambios en Apache Flink y API cualquier Python o JAR dependencia utilizada por las funciones definidas por el usuario. Vuelve a empaquetar tu artefacto personalizado actualizado.
-
Añada estos nuevos conectores y artefactos al nuevo portátil.
-
-
En el nuevo cuaderno, ajuste el código para que sea compatible con cualquier función de Apache Flink que haya cambiado con respecto a la versión anterior.
-
Ejecute el nuevo bloc de notas. Abre el cuaderno y ejecútalo nota por nota, en secuencia, y comprueba si funciona.
-
Realice los cambios necesarios en el código.
-
Detenga la nueva libreta.
-
-
Si hubiera implementado el portátil antiguo como aplicación:
-
Implemente el nuevo portátil como una aplicación nueva e independiente.
-
Detenga la aplicación anterior.
-
Ejecute la nueva aplicación sin la instantánea.
-
-
Detenga el portátil antiguo si está funcionando. Inicie el nuevo bloc de notas, según sea necesario, para un uso interactivo.
Flujo de proceso para la actualización con dependencias externas
