Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy utilizando Kinesis data stream como fuente y Elasticsearch como destino. Estoy usando un trabajo de Flink para procesar un poco los datos y luego enviarlos a Elasticsearch. En el entorno de producción, el flujo de datos de Kinesis puede generar 50,000 eventos por segundo. Se tarda mucho tiempo en . . . Read more
Fondo: He estado intentando configurar BATCH + STREAMING en la misma aplicación de Flink que se despliega en tiempo de ejecución de Kinesis Analytics. La parte de STREAMING funciona bien, pero tengo problemas para agregar soporte para BATCH. https://stackoverflow.com/questions/69795679/flink-handling-keyed-streams-with-data-older-than-application-watermark https://stackoverflow.com/questions/70137863/apache-flink-batch-mode-failing-for-datastream-apis-with-exception-illegalst La lógica es algo así como esto: streamExecutionEnvironment.setRuntimeMode(RuntimeExecutionMode.BATCH); streamExecutionEnvironment.fromSource(FileSource.forRecordStreamFormat(new TextLineFormat(), . . . Read more