r

Author: mymeiyi

be/src/olap/compaction.cpp

@@ -1070,10 +1070,9 @@ void Compaction::agg_and_remove_old_version_delete_bitmap(
             auto d = _tablet->tablet_meta()->delete_bitmap().get_agg(
                     {rowset->rowset_id(), seg_id, pre_max_version});
             to_remove_vec.emplace_back(std::make_tuple(_tablet->tablet_id(), start, end));
-            LOG(INFO) << "sout: add dm to remove for tablet=" << _tablet->tablet_id()
-                      << ", version=" << rowset->version().to_string()
-                      << ", rowset=" << rowset->rowset_id() << ", seg=" << seg_id
-                      << ", start_version=0, end_version=" << pre_max_version;
+            LOG(INFO) << "sout: add a to_remove dm for tablet=" << _tablet->tablet_id()
+                      << ", rowset=" << rowset->rowset_id() << ", seg=" << seg_id << ", version=["
+                      << 0 << ", " << pre_max_version << "]";
             if (d->isEmpty()) {
                 continue;
             }

be/src/olap/tablet.cpp

@@ -831,8 +831,8 @@ void Tablet::delete_expired_stale_rowset() {
         while (to_delete_iter != stale_version_path_map.end()) {
             std::vector<TimestampedVersionSharedPtr>& to_delete_version =
                     to_delete_iter->second->timestamped_versions();
-            LOG(INFO) << "sout: tablet=" << tablet_id() << ", to_delete_version size="
-                      << to_delete_version.size() << ", path_id=" << to_delete_iter->first;
+            LOG(INFO) << "sout: tablet=" << tablet_id()
+                      << ", to_delete_version size=" << to_delete_version.size();
             int64_t start_version = -1;
             int64_t end_version = -1;
             for (auto& timestampedVersion : to_delete_version) {
@@ -863,6 +863,8 @@ void Tablet::delete_expired_stale_rowset() {
             }
             Version version(start_version, end_version);
             version_to_delete.emplace_back(version.to_string());
+            LOG(INFO) << "sout: delete stale dm. tablet=" << tablet_id()
+                      << ", version=" << version.to_string();
             to_delete_iter++;
         }
         _tablet_meta->delete_bitmap().remove_stale_delete_bitmap_from_queue(version_to_delete);

be/src/olap/tablet_meta.cpp

@@ -1238,7 +1238,7 @@ void DeleteBitmap::add_to_remove_queue(
     // val: vector of [tablet_id, {rowset_id, seg_id, start_version}, {rowset_id, seg_id, end_version}]
     // note that the end version is the end version of input rowsets
     _stale_delete_bitmap.emplace(version_str, vector);
-    LOG(INFO) << "sout: tablet_id=" << _tablet_id << ", add key=" << version_str
+    LOG(INFO) << "sout: add_to_remove_queue. tablet_id=" << _tablet_id << ", key=" << version_str
               << ", stale dm size=" << _stale_delete_bitmap.size();
 }
 
@@ -1253,13 +1253,20 @@ void DeleteBitmap::remove_stale_delete_bitmap_from_queue(const std::vector<std::
     for (auto& version_str : vector) {
         auto it = _stale_delete_bitmap.find(version_str);
         if (it != _stale_delete_bitmap.end()) {
+            LOG(INFO) << "sout: remove_stale_delete_bitmap_from_queue. tablet_id=" << _tablet_id
+                      << ", key=" << version_str << ", stale dm size=" << it->second.size();
             for (auto& delete_bitmap_tuple : it->second) {
                 // {rowset_id, seg_id, start_version}
                 if (tablet_id < 0) {
                     tablet_id = std::get<0>(delete_bitmap_tuple);
                 }
                 auto start_bmk = std::get<1>(delete_bitmap_tuple);
                 auto end_bmk = std::get<2>(delete_bitmap_tuple);
+                LOG(INFO) << "sout: remove stale dm, tablet_id=" << tablet_id
+                          << ", rowset=" << std::get<0>(start_bmk).to_string()
+                          << ", seg_id=" << std::get<1>(start_bmk)
+                          << ", start_version=" << std::get<2>(start_bmk)
+                          << ", end_version=" << std::get<2>(end_bmk);
                 // the key range of to be removed is [start_bmk,end_bmk),
                 // due to the different definitions of the right boundary,
                 // so use end_bmk as right boundary when removing local delete bitmap,