Re: The generated schema is not correct when using filesystem connector and avro format

2023-11-19 Thread Hang Ruan
Hi, julia. I have read the code about this part. The problem as you said is that the RowType passed to the avro-confluent format is nullable, which will cause union with null in the schema. I think FLINK-30438 is the same problem as yours. But I find the RowType passed to avro-confluent format in

The generated schema is not correct when using filesystem connector and avro format

2023-11-14 Thread julia bogdan
Hi! I'm facing an issue with the output schema for FileSystemTableSink. In FileSystemTableSink#createWriter (FileSystemTableSink.java#L29