Skip to content

Commit 851197a

Browse files
authored
Merge pull request #3 from dantengsky/wip-mor
fix: filter empty deletion mask locations
2 parents 900bbc3 + 8af75ab commit 851197a

File tree

1 file changed

+4
-7
lines changed
  • src/query/storages/fuse/src/operations

1 file changed

+4
-7
lines changed

src/query/storages/fuse/src/operations/gc.rs

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -270,6 +270,7 @@ impl FuseTable {
270270
delete_locations_to_be_pruged.insert(loc.to_string());
271271
}
272272
status_delete_to_be_purged_count += delete_locations_to_be_pruged.len();
273+
273274
// todo(zhyass): add cache
274275
self.try_purge_location_files_and_cache::<DeleteMarkMeta>(
275276
ctx.clone(),
@@ -484,13 +485,9 @@ impl FuseTable {
484485
.unwrap_or_default()
485486
.0,
486487
);
487-
deletes.insert(
488-
block_meta
489-
.delete_mask_location
490-
.clone()
491-
.unwrap_or_default()
492-
.0,
493-
);
488+
if let Some(mask_location) = &block_meta.delete_mask_location {
489+
deletes.insert(mask_location.0.clone());
490+
}
494491
}
495492
}
496493

0 commit comments

Comments
 (0)