Amazon Managed Service para Apache Flink Amazon (Amazon MSF) se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.
Actualización de tiempo de ejecución de Studio
En esta sección se ofrece información acerca de cómo actualizar el tiempo de ejecución de su cuaderno de Studio. Se recomienda que actualice siempre a la versión de tiempo de ejecución de Studio más reciente compatible.
Actualización de su cuaderno a un nuevo tiempo de ejecución de Studio
En función de cómo se utilice Studio, los pasos para actualizar el tiempo de ejecución varían. Seleccione la opción que se aplique a su caso de uso:
Si se utiliza SQL o Python sin dependencias externas, utilice el siguiente proceso de actualización del tiempo de ejecución. Se recomienda que actualice a la versión de tiempo de ejecución más reciente. El proceso de actualización es el mismo, independientemente de la versión del tiempo de ejecución desde la que se esté actualizando.
-
Creación de un nuevo cuaderno de Studio con la versión de tiempo de ejecución más reciente.
-
Copie y pegue el código de cada nota del antiguo cuaderno al nuevo.
-
En el nuevo cuaderno, ajuste el código para que sea compatible con cualquier característica de Apache Flink que haya cambiado con respecto a la versión anterior.
-
Ejecute el nuevo cuaderno. Abra el cuaderno y ejecútelo nota por nota, en secuencia, y compruebe si funciona.
-
Realice los cambios necesarios en el código.
-
Detenga el cuaderno nuevo.
-
-
Si hubiera implementado el cuaderno antiguo como aplicación:
-
Implemente el nuevo cuaderno como una aplicación nueva e independiente.
-
Detenga la aplicación antigua.
-
Ejecute la nueva aplicación sin una instantánea.
-
-
Detenga el cuaderno antiguo si está funcionando. Inicie el nuevo cuaderno, según sea necesario, para un uso interactivo.
Flujo de proceso para la actualización sin dependencias externas
Siga este proceso si utiliza SQL o Python y dependencias externas, como conectores o artefactos personalizados, como funciones definidas por el usuario implementadas en Python o Java. Se recomienda que actualice al tiempo de ejecución más reciente. El proceso de actualización es el mismo, independientemente de la versión del tiempo de ejecución desde la que se esté actualizando.
-
Creación de un nuevo cuaderno de Studio con la versión de tiempo de ejecución más reciente.
-
Copie y pegue el código de cada nota del antiguo cuaderno al nuevo.
-
Actualiza las dependencias externas y los artefactos personalizados.
-
Busque nuevos conectores compatibles con la versión Apache Flink del nuevo tiempo de ejecución. Consulte los conectores Table y SQL
en la documentación de Apache Flink para encontrar los conectores adecuados para la versión de Flink. -
Actualice el código de las funciones definidas por el usuario para que coincida con los cambios en la API de Apache Flink y cualquier dependencia de Python o JAR utilizada por las funciones definidas por el usuario. Vuelva a empaquetar el artefacto personalizado actualizado.
-
Añada estos nuevos conectores y artefactos al nuevo cuaderno.
-
-
En el nuevo cuaderno, ajuste el código para que sea compatible con cualquier característica de Apache Flink que haya cambiado con respecto a la versión anterior.
-
Ejecute el nuevo cuaderno. Abra el cuaderno y ejecútelo nota por nota, en secuencia, y compruebe si funciona.
-
Realice los cambios necesarios en el código.
-
Detenga el cuaderno nuevo.
-
-
Si hubiera implementado el cuaderno antiguo como aplicación:
-
Implemente el nuevo cuaderno como una aplicación nueva e independiente.
-
Detenga la aplicación antigua.
-
Ejecute la nueva aplicación sin una instantánea.
-
-
Detenga el cuaderno antiguo si está funcionando. Inicie el nuevo cuaderno, según sea necesario, para un uso interactivo.
Flujo de proceso para la actualización con dependencias externas
