使用Flink对hudi MOR表进行离线压缩

默认情况下，MERGE_ON_READ表的压缩是启用的。触发器策略是在完成五次提交后执行压缩。因为压缩会消耗大量内存，并且与写操作处于相同的管道中，所以当数据量很大(> 100000 /秒)时，很容易干扰写操作。此时，使用离线压缩能够更稳定地执行压缩任务。

压缩任务的执行包括两个部分:计划压缩计划和执行压缩计划。建议调度压缩计划的进程由写任务周期性触发，默认情况下写参数compact.schedule.enable为启用状态。

离线压缩需要在命令行上提交Flink任务。程序入口如下: hudi-flink-bundle_2.12-0.9.0.jar : org.apache.hudi.sink.compact.HoodieFlinkCompactor

命令行：

./bin/flink run -c org.apache.hudi.sink.compact.HoodieFlinkCompactor lib/hudi-flink-bundle_2.11-0.9.0.jar --path hdfs://xxx:9000/table

相关参数：

参数名	是否必须	默认值	参数含义
`--path`	`frue`	`--`	存储在hudi上的表的路径
`--compaction-max-memory`	`false`	`100`	压缩期间日志数据的索引映射大小，默认为100 MB。如果您有足够的内存，您可以打开这个参数
`--schedule`	`false`	`false`	是否执行调度压缩计划的操作。当写进程仍在写时，打开此参数有丢失数据的风险。因此，开启该参数时，必须确保当前没有写任务向该表写入数据
`--seq`	`false`	`LIFO`	压缩任务执行的顺序。默认情况下从最新的压缩计划执行。 LIFI:从最新的计划开始执行。 FIFO:从最古老的计划执行。