Re: Interaction between idling sources and watermark alignment

2023-06-13 Thread Alexis Sarda-Espinosa
Hi again, I'm not a fan of bumping questions, but I think this might be relevant, maybe enough to include it in the official documentation? Regards, Alexis. On Tue, 30 May 2023, 16:07 Alexis Sarda-Espinosa, wrote: > Hello, > > I see that, in Flink 1.17.1, watermark alignment will be supported (

Flink File source with Parquet reader API - 1.16.x

2023-06-13 Thread Kamal Mittal via user
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 ho