r

Author: mymeiyi

be/src/olap/compaction.cpp

@@ -1314,6 +1314,7 @@ Status CompactionMixin::modify_rowsets() {
         if (!st.ok()) {
             LOG(WARNING) << "failed to remove old version delete bitmap, st: " << st;
         }
+        LOG(INFO) << "sout: finish compaction for tablet=" << _tablet->tablet_id() << " --------- ";
     }
 
     return Status::OK();

be/src/olap/tablet.cpp

@@ -831,7 +831,7 @@ 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()
+            LOG(INFO) << "sout: delete_expired_stale_rowset for tablet=" << tablet_id()
                       << ", to_delete_version size=" << to_delete_version.size();
             int64_t start_version = -1;
             int64_t end_version = -1;

be/src/olap/tablet_meta.cpp

@@ -1239,7 +1239,7 @@ void DeleteBitmap::add_to_remove_queue(
     // note that the end version is the end version of input rowsets
     _stale_delete_bitmap.emplace(version_str, vector);
     LOG(INFO) << "sout: add_to_remove_queue. tablet_id=" << _tablet_id << ", key=" << version_str
-              << ", stale dm size=" << _stale_delete_bitmap.size();
+              << ". queue size=" << _stale_delete_bitmap.size();
 }
 
 void DeleteBitmap::remove_stale_delete_bitmap_from_queue(const std::vector<std::string>& vector) {
@@ -1253,16 +1253,17 @@ 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();
+            LOG(INFO) << "sout: start 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
+                LOG(INFO) << "sout: now 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)

be/src/olap/tablet_meta_manager.cpp

@@ -292,7 +292,7 @@ Status TabletMetaManager::remove_old_version_delete_bitmap(DataDir* store, TTabl
         return true;
     };
     RETURN_IF_ERROR(meta->iterate(META_COLUMN_FAMILY_INDEX, begin_key, get_remove_keys_func));
-    LOG(INFO) << "remove old version delete bitmap, tablet_id: " << tablet_id
+    LOG(INFO) << "sout: remove old version delete bitmap, tablet_id: " << tablet_id
               << " version: " << version << ", removed keys size: " << remove_keys.size();
     return meta->remove(META_COLUMN_FAMILY_INDEX, remove_keys);
 }