es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Tag: AUDIO-STREAMING

NullpointException al leer un archivo con RowCsvInputFormat en Flink.

Soy principiante en Flink streaming. Cuando leo un archivo con RowCsvInputFormat, el código que el serializador Kryo crea para Row no funciona correctamente. El código es el siguiente. val readLocalCsvFile = new RowCsvInputFormat( new Path(“flink-test/000000_1”), Array(Types.STRING, Types.STRING, Types.STRING), “\n”, “,” ) val read = env.readFile( readLocalCsvFile, “flink-test/000000_1”, FileProcessingMode.PROCESS_CONTINUOUSLY, 1000000 ) . . . Read more