Implemente como una aplicación con un estado duradero

Los párrafos deben ordenarse secuencialmente. Al implementar la aplicación, todos los párrafos de una nota se ejecutarán secuencialmente (left-to-right, top-to-bottom) tal como aparecen en la nota. Para comprobar este orden, seleccione Ejecutar todos los párrafos en la nota.

Su código es una combinación de Python SQL o Scala ySQL. No admitimos Python y Scala juntos en este momento. deploy-as-application

Su nota solo debe tener los siguientes intérpretes: %flink, %flink.ssql, %flink.pyflink, %flink.ipyflink, %md.

No se admite el uso del objeto z de contexto Zeppelin. Los métodos que no devuelven nada no harán nada excepto registrar una advertencia. Otros métodos generarán excepciones de Python o no se compilarán en Scala.

Una nota debe dar como resultado un único trabajo de Apache Flink.

Las notas con formularios dinámicos no se admiten para su implementación como una aplicación.

Los párrafos de %md (Markdown) se omitirán al implementar una aplicación, ya que se espera que contengan documentación legible por humanos que no es adecuada para ejecutarse como parte de la aplicación resultante.

Los párrafos que estén deshabilitados para ejecutarse en Zeppelin se omitirán al implementarse como una aplicación. Incluso si un párrafo desactivado utiliza un intérprete incompatible, por ejemplo, %flink.ipyflink en una nota con %flink and %flink.ssql intérpretes, se omitirá al implementar la nota como una aplicación y no se producirá ningún error.

Debe haber al menos un párrafo con el código fuente (Flink PyFlink o Flink SQL Scala) que esté habilitado para ejecutarse para que la aplicación se despliegue correctamente.

La configuración del paralelismo en la directiva del intérprete dentro de un párrafo (por ejemplo, %flink.ssql(parallelism=32)) no se tendrá en cuenta en las aplicaciones que se implementen a partir de una nota. En su lugar, puede actualizar la aplicación desplegada mediante o cambiar el AWS Management Console paralelismo AWS Command Line Interface o AWS API la ParallelismPer KPU configuración según el nivel de paralelismo que requiera la aplicación, o bien puede activar el escalado automático de la aplicación implementada.

Si va a realizar la implementación como una aplicación con un estado duradero, debe tener acceso a Internet. VPC Si VPC no tiene acceso a Internet, consulteImplemente como una aplicación con un estado duradero en un lugar VPC sin acceso a Internet.

En tu código de Scala o Python, use el planificador Blink (senv, stenv para Scala; s_env, st_env para Python) y no el antiguo planificador “Flink” (stenv_2 para Scala, st_env_2 para Python). El proyecto Apache Flink recomienda el uso del planificador de Blink para los casos de uso de producción, que es el planificador predeterminado en Zeppelin y Flink.

Sus párrafos de Python no deben usar invocaciones ! o asignaciones de shell que utilicen comandos IPython mágicos como %timeit o %conda en notas destinadas a implementarse como aplicaciones.

No puede usar las clases de mayúsculas y minúsculas de Scala como parámetros de funciones que se pasan a operadores de flujo de datos de orden superior, como map y filter. Para obtener información sobre las clases de casos de Scala, consulte CASECLASSESla documentación de Scala.

No se permiten SELECT declaraciones simples, ya que no hay ningún lugar equivalente a la sección de salida de un párrafo en el que se puedan entregar los datos.

En cualquier párrafo dado, DDL las declaraciones (USE,CREATE,ALTER, DROPSET,RESET) deben preceder a las declaraciones DML (INSERT). Esto se debe a que DML las declaraciones de un párrafo deben enviarse juntas como un solo trabajo de Flink.

Debe haber como máximo un párrafo que contenga DML declaraciones. Esto se debe a que, para esta deploy-as-application función, solo admitimos el envío de un único trabajo a Flink.