I use spark struct stream add record to hudi merge on read table it and it produce so many small parquet files 