Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
¿Por qué divide flink la tubería en varios trabajos si hay un execute_insert en la tubería? docker-compose exec jobmanager ./bin/flink run –pyModule my.main -d –pyFiles /opt/pyflink/ -d Se ha enviado el trabajo con el ID de trabajo 3b0e179dad500a362525f23e82e2c826 Se ha enviado el trabajo con el ID de trabajo 93d122a6331b4b9ec2578fe67e748a8e Fin . . . Read more
Soy un traductor de IT que traduce documentos. Traduzca lo siguiente al español. No traduzca el código y la salida en markdown. Soy un principiante en el marco de pyflink y me gustaría saber si es posible con él mi caso de uso … Necesito crear ventanas de desplazamiento y . . . Read more
Recientemente comencé a utilizar Flink para el procesamiento de datos. Cuando intenté ejecutar la API de tablas para contar hashtags importando pyflink, no pude importar OldCsv y FileSystem desde pyflink.table.descriptors. También descargué Apache Flink utilizando: pip install apache-flink Librerías importadas: from pyflink.table import DataTypes, TableEnvironment, EnvironmentSettings from pyflink.table.descriptors import Schema, . . . Read more
Estoy tratando de escribir un paquete local en el proyecto PyFlink. Pero solo puedo importar utilizando una ruta relativa. Como por ejemplo: from .paquete import funcion ¿Puedo usar rutas absolutas en paquetes dentro del proyecto PyFlink, importados como env.add_python_file(‘/ruta_al_proyecto’)?