Hudi Savepoint操作说明
Savepoint用于保存并还原自定义的版本数据。
Hudi提供的savepoint就可以将不同的commit保存起来以便清理程序不会将其删除,后续可以使用Rollback进行恢复。
使用spark-sql管理savepoint。
示例如下:
- 创建savepoint
call create_savepoint('hudi_test1', '20220908155421949');
- 查看所有存在的savepoint
call show_savepoints(table =>'hudi_test1');
- 回滚savepoint
call rollback_to_savepoint('hudi_test1', '20220908155421949');
savepoint的rollback与commit rollback相同,都必须从最新的instant逐个向前rollback。
MRS 3.1.2版本:MoR表暂时不支持savepoint。