Tag: KRYO

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