DLF存储优化支持表级自适应Compaction、过期快照清理、分区生命周期管理、废弃文件清理等能力,帮助用户降低Paimon表使用和运维复杂度,提升计算和存储的使用效率。本文讲述DLF后台执行的智能存储优化策略及其执行机制。
产品在邀测阶段,暂不收取存储优化所使用的计算资源费用。
存储优化策略介绍
策略类型 | 描述 | DLF执行机制 |
Compaction功能通过合并小文件为较大文件,减少文件数量,进而降低元数据管理开销和查询时的文件查找成本,提升查询性能,增强Paimon表的查询效率。 | 在用户执行Commit写入数据时,DLF自动触发Compaction。 | |
为了保证快照文件对应的历史状态可以被正常读取,只要快照文件存在,其指向的历史数据文件就不能被删除。随着快照文件不断产生,历史数据占用的存储空间也将逐渐增加。因此需要淘汰不再使用的快照文件,以释放它们所指向的、不再活跃的历史数据空间,从而实现存储资源的有效管理与释放。 | 在DLF存储优化作业执行时,DLF自动触发快照清理。快照过期时间默认为1小时。用户可通过Paimon表参数调整过期时间,详见清理过期数据。 | |
业务场景通常只需访问近期数据,在这种情况下可以按时间对数据进行分区,并设置分区过期时间以自动删除过于久远的历史分区,从而释放存储空间。此外,您可以进行存储分层配置,将访问频率较低的分区数据从高性能存储(如标准存储)迁移至低成本存储(如低频、归档或冷归档存储),从而在满足业务需求的同时降低存储成本。 | 用户可通过Paimon表参数配置过期时间,详见设置分区过期时间。配置参数后,会在DLF存储优化作业执行时自动触发。同时,您也可以通过配置智能存储分层,将符合条件的分区数据自动迁移至指定的存储类型(如标准、低频、归档或冷归档存储),也可以在表详情页面手动修改存储类型。通过存储概览,您可查看数据目录、数据库以及数据表的存储分层分布情况。 | |
由于作业报错、重启等原因,Paimon 表目录下可能会遗留一些未被提交的临时文件。这些废弃文件未被任何快照引用,因此无法通过快照过期机制删除,需定期进行清理。 | 废弃文件保留时长默认为7天,超过该时间的废弃文件将被视为过期并自动清理,因此DLF每7天触发一次清理任务。 |
开启/关闭智能存储优化
存储优化功能在表级别默认开启,支持手动关闭。
智能存储优化开启中,系统会自动进行Compaction、过期快照清理、废弃文件清理。如果您希望系统自动进行分区生命周期管理,请先配置生命周期规则,请参见分区生命周期管理。
登录数据湖构建控制台。
在Catalog列表页面,单击Catalog名称。
在数据库页签中,单击目标数据库名称,查看数据表。
在表列表中,单击目标表名称,查看表字段信息。
单击存储优化页签,可看到智能存储优化开关默认开启,单击
开关,即可关闭。
查看与配置存储优化策略
Compaction
在存储优化页签,单击Compaction,您可查看小文件合并的执行情况,如执行状态、待Compaction数据延迟时间。
过期快照清理
在存储优化页签,单击Snapshot Expire,您可以配置快照清理规则并查看快照清理结果。
配置快照清理规则
单击编辑,您可以设置快照保留时间(默认为1小时),单击保存,完成配置。
查看快照清理结果
当前Snapshot个数:实时显示当前剩余的快照数量。
最早Snapshot信息:展示表中最早的快照详情,包括快照ID、提交时间、提交类型、表总行数以及本提交增加行数。
分区生命周期管理
在存储优化页签,单击Partition LifeCycle,您可以进行分区清理规则配置、查看分区清理结果、存储分层配置。
分区清理规则配置
单击启用分区清理右侧的
开关,可启用分区清理。
启用分区清理后,您可根据业务需求进行以下规则配置,单击保存,完成配置。
配置项
说明
过期策略
可选择以下过期策略:
最近访问时间:根据分区数据最近访问时间,进行过期判断。
分区值:根据分区值(values-time)进行过期判断,可以配置分区时间戳格式和分区字段模式。
时间戳格式:对应表配置项
partition.timestamp-formatter
。可配置比如yyyy-MM-dd
、yyyyMMdd
、dd/MM/yyyy
、dd.MM.yyyy
等。时间戳模式:对应表配置项
partition.timestamp-pattern
,默认取第一个分区字段,可配置比如$dt
或者$year-$month-$day
等。
最后更新时间:按照最细粒度分区数据最后更新时间进行过期判断
分区保留时间
最大可设置为999999天。分区保留时间根据所选过期策略,判定起始时间。
(可选)保存之后,也可单击规则配置右侧的编辑,进行再次修改。
说明若您希望永久保留分区,则无需配置分区过期清理规则,系统默认不会自动清理分区数据。
查看分区清理结果
单击点击查看分区列表,可查看当前数据表的分区列表,包括分区名、行数(物理)、引用的文件个数、总文件大小、创建人、存储类型、最新更新人、创建时间、最近更新时间及操作。
存储分层配置
配置项
说明
智能存储分层
开启后,系统将根据您配置的生命周期规则,自动对Catalog下所有表进行冷热分层。请根据业务需求填写分层策略和分层规则。
说明如果Catalog级别开启智能分层,那么Table级别的智能存储分层会默认开启(继承自Catalog),并支持在Table级别修改配置。如果在表级别修改规则,则不再展示继承自Catalog。
如果Catalog级别未开启智能分层,也支持在Table级别开启,并支持修改。
分层策略
最后访问时间:根据表/分区数据最后访问时间,进行规则判断。
最后更新时间:按照表/分区数据最后更新时间,进行规则判断。
分层规则
不同存储类型的最低存储时间要求不同。
存储类型
最低存储时间
低频访问存储
30天
归档存储
60天
冷归档存储
180天
您可选择性配置以下分层规则:
转换至低频访问存储
配置天数:自定义,默认30天。
数据最后访问时间超过该天数后,将会自动转为低频存储。低频存储依旧可以被计算引擎访问,但性能会有所下降。
被访问自动转标准存储:如果勾选,在表/分区被访问时,系统会自动将该分区或非分区表转换为标准存储。
说明仅在分层策略选择基于“最后访问时间”时支持该功能。
转换至归档存储
配置天数:自定义,默认60天。
数据最后访问时间超过该天数后,将会自动转为归档存储。归档存储的数据,将无法被计算引擎访问。
被访问自动转标准存储:如果勾选,在表/分区被访问时,系统会自动将该分区或非分区表转换为标准存储。
说明仅在分层策略选择基于“最后访问时间”时支持该功能。
转换至冷归档存储
配置天数:自定义,默认180天。
数据最后访问时间超过该天数后,将会自动转为冷归档存储。归档存储的数据,将无法被计算引擎访问。
废弃文件清理
在存储优化页签,单击Orphan File Remove,您可查看废弃文件清理规则。例如,废弃文件的保留时间默认为7天(根据文件写入时间判断),超过该时间的过期废弃文件将被系统自动清理。
手动修改存储类型
在数据库列表中,单击数据库名称,可查看表列表。
在表列表中,单击表名称,可查看表字段。
单击表详情页签,您可以手动修改分区表和非分区表的存储类型。
分区表
在分区列表页签,您可以对不同存储类型的分区进行存储类型修改操作。
标准、低频、归档存储类型的分区:
单击操作列的修改存储类型,支持修改为除当前存储类型外的其他存储类型。
冷归档存储类型的分区:
需先解冻,待解冻完成并恢复为已解冻状态后,才可以转换存储类型。具体操作如下:
单击解冻,可配置解冻状态持续时间,支持选择分区批量解冻。
取值范围:1~365 的正整数(单位:天)。
默认值:1天。
当数据进入已解冻状态时,单击操作列的修改存储类型,可修改为其他存储类型。
非分区表
在表的基本信息中,您可以对存储类型进行修改。
标准、低频、归档存储类型
单击存储类型右侧的修改,支持修改为除当前存储类型外的其他存储类型。
冷归档存储类型
需先解冻,待解冻完成并恢复为已解冻状态后,才可以转换存储类型。具体操作如下:
单击存储类型右侧的解冻,可配置解冻状态持续时间。
取值范围:1~365 的正整数(单位:天)。
默认值:1天。
当存储类型变为冷归档(已解冻)后,单击存储类型右侧的修改,支持修改为除当前存储类型外的其他存储类型。
说明解冻消耗时间:是指解冻Object所消耗的时间。冷归档存储类型的解冻优先级仅支持标准,解冻消耗时间为2~5小时内完成解冻。
解冻状态开始时间:是指分区内第一个冷归档存储类型的Object在完成解冻操作后,正式进入“已解冻”状态的时间点。
解冻状态持续时间:是指分区内第一个冷归档存储类型的Object在完成解冻后,数据处于“已解冻”状态的有效时长。待分区内所有Object均完成解冻后,您可以对分区进行正常的读取、写入或存储类型转换等操作。一旦解冻状态持续时间结束,分区中的数据将重新回到冷归档状态,无法直接访问,需要再次解冻才能操作。
解冻过程
初始时,Object处于冷冻状态。
用户提交解冻请求后,Object处于解冻中状态。解冻消耗时间请以实际为准。
服务端完成解冻任务后,Object进入已解冻状态。对于表级存储分层而言,当分区内所有对象均完成解冻后,该分区即可正常访问。
您可以通过调整分区解冻状态持续时间来延长解冻状态的总时长,但总时长不能超过该存储类型允许的解冻状态持续时间的最大限制。
解冻状态持续时间结束后,Object再次返回到冷冻状态,且不改变Object原有的存储类型。若后续仍需访问数据,则需重新提交解冻请求,并等待解冻完成。