Skip to content

Commit ca41413

Browse files
committed
[fix](storage-engine) _clean_unused_rowset_metas should skip rowsets in _unused_rowsets map
1 parent d336eed commit ca41413

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

be/src/olap/storage_engine.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -957,7 +957,8 @@ void StorageEngine::_clean_unused_rowset_metas() {
957957
return true;
958958
}
959959
if (rowset_meta->rowset_state() == RowsetStatePB::VISIBLE &&
960-
(!tablet->rowset_meta_is_useful(rowset_meta))) {
960+
(!tablet->rowset_meta_is_useful(rowset_meta)) &&
961+
!check_rowset_id_in_unused_rowsets(rowset_id)) {
961962
LOG(INFO) << "rowset meta is not used any more, remove it. rowset_id="
962963
<< rowset_meta->rowset_id();
963964
invalid_rowset_metas.push_back(rowset_meta);

be/src/olap/tablet.cpp

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -920,8 +920,10 @@ void Tablet::delete_expired_stale_rowset() {
920920
if (config::enable_mow_verbose_log) {
921921
LOG_INFO("finish delete_expired_stale_rowset for tablet={}", tablet_id());
922922
}
923-
DBUG_EXECUTE_IF("Tablet.delete_expired_stale_rowset.start_delete_unused_rowset",
924-
{ _engine.start_delete_unused_rowset(); });
923+
DBUG_EXECUTE_IF("Tablet.delete_expired_stale_rowset.start_delete_unused_rowset", {
924+
_engine.start_delete_unused_rowset();
925+
[[maybe_unused]] auto st = _engine.start_trash_sweep(nullptr);
926+
});
925927
}
926928

927929
Status Tablet::check_version_integrity(const Version& version, bool quiet) {

0 commit comments

Comments
 (0)