File tree Expand file tree Collapse file tree 2 files changed +6
-3
lines changed
Expand file tree Collapse file tree 2 files changed +6
-3
lines changed Original file line number Diff line number Diff 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);
Original file line number Diff line number Diff 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
927929Status Tablet::check_version_integrity (const Version& version, bool quiet) {
You can’t perform that action at this time.
0 commit comments