Anyone familiar with CompactOperator in parquet? I am trying to use

auto-compaction

on Hive and i found that the watermark of Compact operator is the slowest for Flink with Hive sink. Could you suggest me how to optimize it a bit. I am trying to write data every 5 minutes ( checkpoint interval ) and compacted file size is only about 200MB max.