使用Flink+paimon的场景，出现很多的小文件导致反压或者阻塞怎么办？

1、进行Checkpoint的时候会强制把当前的WriteBuffer的数据刷到磁盘上
2、WriteBuffer本身满了也会刷到磁盘上

1、Checkpoint interval：推荐在1-2min比较合适(这是很多公司的场景给出的推荐参数，但是根据个人实践情况来看，这个频率有些高，实际上3-5min或者更长一点时间更为合理);
2、WriteBuffer大小：推荐使用默认值，如果你的数据规模比较大，那么可以适当增加增加write-buffer-size或开启write-buffer-spillable选项，这样溢写到HDFS上生成的文件更大。
3、业务数据量：根据业务数据量调节Bucket数，调整依据为单个Bucket大小在1G左右合适(可以稍高一点)；
4、Key的设置：根据实际的业务Key特点设置合适的Bucket-key、Partition，防止热Key倾斜问题；
5、Compaction相关参数：优先使用默认值。这里有一个注意的点，生产环境是比较推荐开启异步Compaction的，可以通过下面三个参数开启：
'num-sorted-run.stop-trigger' = '2147483647',  -- 极大值，减少写入暂停
'sort-spill-threshold' = '10',                  -- 防止内存溢出
'changelog-producer.lookup-wait' = 'false'      -- 禁用同步等待，实现异步