请问Flink有大佬知道怎么把hudi的数据删除吗？是真正的删除 hdfs 上的数据，太占磁盘了，

可以直接在 HDFS 上把分区 rm 掉，但是这可能会导致数据丢失。

建议使用 hudi.cleaner.policy 配置参数来删除历史数据。hudi.cleaner.policy 可以配置为以下几种类型：

delete: 删除历史数据。
archive: 归档历史数据。
compact: 压缩历史数据。
默认情况下，hudi.cleaner.policy 的值为 archive。

如果需要删除历史数据，可以将 hudi.cleaner.policy 的值设置为 delete。

例如，以下代码会删除历史数据：

-- 配置参数
hudi.cleaner.policy=delete

-- 启动 Flink
flink run -c com.example.MyJob /path/to/myjob.jar
注意，删除历史数据是一个非常耗时的操作。需要提前规划好删除历史数据的策略，以免影响正常的数据业务。

参考资料