Hello, Flink File source API as below used for reading AVRO - Parquet records. If any record comes "null or is made null in between of a split in AVROParquetReader > read() method" due to "bad record" situation then whole file split is stopped/discarded.
Can you please guide about this that how to handle both situations i.e. bad record as well as split completion? API - FileSource.FileSourceBuilder<?> source = FileSource.forRecordStreamFormat(streamformat, path); Let me know please if needed more info. Rgds, Kamal
