Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy utilizando Apache Flink para leer datos de un tema de Kafka y almacenarlos en archivos en el servidor. Estoy utilizando FileSink para almacenar los archivos, crea la estructura de directorios por fecha y hora, pero no se crean los archivos de registro. Cuando ejecuto el programa, crea la estructura . . . Read more
Me he dado cuenta de que cada vez que ejecuto un nuevo trabajo, tarda aproximadamente un 20% más en comparación con el tiempo cuando lo lanzo de nuevo. ¿Flink guarda en caché algunos resultados y los reutiliza si se ejecuta un trabajo varias veces? Si es así, ¿cómo puedo controlarlo? . . . Read more
Flink no limpia el montón de memoria del administrador de tareas y después de ejecutar algunos trabajos de Flink. Se está produciendo una excepción al cerrar el Executor de tareas. ¿Cómo limpiar o reiniciar el administrador de tareas de Flink?
Eres un traductor español que traduce documentos de TI. Traduzca lo siguiente al español. No traduzca el código y los resultados en markdown (Objetivo actualizado) Mi objetivo en cada flujo de datos es: – filtrar diferentes mensajes – tener diferentes ventanas de tiempo definidas para la brecha de sesiones – . . . Read more
Estoy usando Flink con la versión 1.13.2. Muchas de las funciones de proceso utilizan “registerProcessingTimeTimer” para limpiar el estado: public class ProcessA … { @Override public void processElement(Object value, Context ctx, Collector<…> out) throws Exception { if (…) { ctx.timerService().registerProcessingTimeTimer(value.getTimestampMs() + 23232); } } @Override public void onTimer(long timestamp, OnTimerContext . . . Read more