Resultados de la búsqueda a petición "flink-streaming"
Orden de registros en secuencia
Estas son algunas de las consultas que tengo: Tengo dos transmisiones diferentesstream1 ystream2 en el que los elementos están en orden. 1) Ahora cuando lo hagokeyBy en cada una de estas transmisiones, ¿se mantendrá el orden? (Dado que cada ...
Apache Flink: Cómo contar el número total de eventos en un DataStream
Tengo dos transmisiones sin procesar y me estoy uniendo a esas transmisiones y luego quiero contar cuál es el número total de eventos que se han unido y cuántos eventos no. Estoy haciendo esto usando el mapa enjoinedEventDataStream Como se ...
Flink CEP Sin resultados impresos
Estoy tratando de imprimir una cadena si se encuentran Hello y world usando la biblioteca Flink CEP. Mi fuente es Kafka y utilizo el productor de consola para ingresar los datos. Esa parte está funcionando. Puedo imprimir lo que ingreso en el ...
¿Cuál es la diferencia principal entre Flink y Storm?
Flink ha sidoen comparación con Spark [https://stackoverflow.com/questions/28082581/what-is-the-differences-between-apache-spark-and-apache-flink] , que, según lo veo, es la comparación incorrecta porque compara un sistema de procesamiento de ...
Apache parpadea en Kubernetes - Reanuda el trabajo si el administrador de trabajos falla
Quiero ejecutar un trabajo de parpadeo en kubernetes, usando un backend de estado (persistente) parece que los administradores de tareas bloqueados no son un problema, ya que pueden preguntarle al administrador de trabajos de qué punto de control ...