Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Actualmente tenemos una aplicación de AWS Kinesis Data Analytics que requiere un archivo .jar para ejecutarse. Hemos automatizado la implementación de nuestro archivo .jar que se encuentra en un cubo S3. Nuestro problema es que, cada vez que se actualiza el archivo .jar, nos vemos obligados a reiniciar la aplicación . . . Read more
Creé una tabla de compras utilizando el conector Kafka (usando Flink SQL): CREATE TABLE purchases ( country STRING, product STRING ) WITH ( ‘connector’ = ‘kafka’, ‘topic’ = ‘purchases’, ‘properties.bootstrap.servers’ = ‘kafka:29092’, ‘value.format’ = ‘json’, ‘properties.group.id’ = ‘1’, ‘scan.startup.mode’ = ‘earliest-offset’ ); Luego realizo la siguiente agregación en Apache Flink: . . . Read more
Cuando aplico el método countWindow a un KeyedStream, obtengo una GlobalWindow y no un CountWindow. ¿Alguien sabe por qué? No puedo encontrar nada en la documentación de Flink. ¡Gracias! java WindowedStream<share, string,=”” globalwindow=””> windowedStream2 = keyed.countWindow(100, 10);</share,>
Soy nuevo en el marco de transmisión de Flink y estoy tratando de entender los componentes y el flujo. Estoy tratando de ejecutar el ejemplo básico de conteo de palabras utilizando DataStream. Estoy tratando de ejecutar el código en mi IDE. El código se ejecuta sin problemas cuando alimento los . . . Read more
Necesito analizar los mensajes de Kafka de Confluent almacenados en Avro. Pero al aplicar el filtro me da una excepción de puntero nulo, sin filtro pude escribir de vuelta en Kafka, pero al aplicar el filtro me da una excepción de puntero nulo. public static void main(String[] args) throws Exception . . . Read more