Resultados de la búsqueda a petición "apache-flink"
¿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 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 ...
¿Cómo usar Flink's KafkaSource en Scala?
Estoy tratando de ejecutar un programa de prueba simple con KafkaSource de Flink. Estoy usando lo siguiente: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Seguí los documentos para probar KafkaSource (dependencia agregada, agrupar el conector Kafka ...
Leer datos de Cassandra para procesar en Flink
Tengo que procesar flujos de datos de Kafka usando Flink como motor de transmisión. Para hacer el análisis de los datos, necesito consultar algunas tablas en Cassandra. ¿Cuál es la mejor manera de hacer esto? He estado buscando ejemplos en Scala ...
java.lang.NoSuchMethodError en Flink
Estoy tratando de leer el archivo usando: final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); DataSet<String> line = env.readTextFile("file:///pathtofile/myfile.txt");Me sale el siguiente ...
¿Cuál es la diferencia entre un sistema "con estado" y "sin estado"?
Apache Spark [https://people.csail.mit.edu/matei/papers/2013/sosp_spark_streaming.pdf]se jacta de que sus operadores (nodos) están "sin estado". Esto permite que la arquitectura de Spark utilice protocolos más simples para cosas ...
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 ...
¿Cómo puedo iniciar la interfaz web del administrador de trabajos de Flink cuando ejecuto Flink desde un IDE?
Me gustaría acceder a la interfaz web de Flink cuando la inicie localmente desde el IDE. Necesito esto porque me gustaría acceder a los contadores (acumuladores) de Flink.
Clasificación global en Apache Flink
El método sortPartition de un conjunto de datos clasifica el conjunto de datos localmente en función de algunos campos especificados. ¿Cómo puedo ordenar mi conjunto de datos grande globalmente de manera eficiente en Flink?
Combina dos transmisiones en Apache Flink independientemente del tiempo de ventana
Tengo dos flujos de datos que quiero combinar. El problema es que un flujo de datos tiene una frecuencia mucho más alta que el otro y hay momentos en que un flujo no recibe eventos en absoluto. ¿Es posible usar el último evento de una transmisión ...