From 93dc0963e191f606fa81f12c2a6bbf6df126c2f7 Mon Sep 17 00:00:00 2001
From: Tsunaou <895254752@qq.com>
Date: Tue, 11 Feb 2025 20:16:03 +0000
Subject: [PATCH] fix init tablet ls pair cache map && add truncate info stat
 event

---
 .../oblib/src/lib/statistic_event/ob_stat_event.h |  2 ++
 .../freeze/ob_major_merge_progress_util.cpp       | 15 ++++++++++++++-
 2 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/deps/oblib/src/lib/statistic_event/ob_stat_event.h b/deps/oblib/src/lib/statistic_event/ob_stat_event.h
index bf909b1089..8390f945c7 100644
--- a/deps/oblib/src/lib/statistic_event/ob_stat_event.h
+++ b/deps/oblib/src/lib/statistic_event/ob_stat_event.h
@@ -286,6 +286,8 @@ STAT_EVENT_ADD_DEF(BACKUP_INDEX_CACHE_HIT, "backup index cache hit", ObStatClass
 STAT_EVENT_ADD_DEF(BACKUP_INDEX_CACHE_MISS, "backup index cache miss", ObStatClassIds::CACHE, 50072, true, true, true)
 STAT_EVENT_ADD_DEF(BACKUP_META_CACHE_HIT, "backup meta cache hit", ObStatClassIds::CACHE, 50073, true, true, true)
 STAT_EVENT_ADD_DEF(BACKUP_META_CACHE_MISS, "backup meta cache miss", ObStatClassIds::CACHE, 50074, true, true, true)
+STAT_EVENT_ADD_DEF(TRUNCATE_INFO_CACHE_HIT, "truncate info cache hit", ObStatClassIds::CACHE, 50075, true, true, true)
+STAT_EVENT_ADD_DEF(TRUNCATE_INFO_CACHE_MISS, "truncate info cache miss", ObStatClassIds::CACHE, 50076, true, true, true)
 
 // STORAGE
 STAT_EVENT_ADD_DEF(MEMSTORE_LOGICAL_READS, "MEMSTORE_LOGICAL_READS", STORAGE, "MEMSTORE_LOGICAL_READS", true, true, false)
diff --git a/src/rootserver/freeze/ob_major_merge_progress_util.cpp b/src/rootserver/freeze/ob_major_merge_progress_util.cpp
index 9b7cbf2cb7..40857d8e1b 100644
--- a/src/rootserver/freeze/ob_major_merge_progress_util.cpp
+++ b/src/rootserver/freeze/ob_major_merge_progress_util.cpp
@@ -20,6 +20,7 @@ using namespace share;
 using namespace common;
 namespace compaction
 {
+ERRSIM_POINT_DEF(EN_COMPACTION_SKIP_CREATE_MAP);
 
 ObTableCompactionInfo &ObTableCompactionInfo::operator=(const ObTableCompactionInfo &other)
 {
@@ -160,6 +161,11 @@ int ObTabletLSPairCache::refresh()
                 K(tablet_ls_pair_array));
       } else if (tablet_ls_pair_array.empty()) {
         break;
+#ifdef ERRSIM
+      } else if (OB_UNLIKELY(EN_COMPACTION_SKIP_CREATE_MAP)) {
+        LOG_INFO("ERRSIM EN_COMPACTION_SKIP_CREATE_MAP, skip set map"); // tablet_ls_pair_array is empty
+        break;
+#endif
       } else {
         for (int64_t idx = 0; OB_SUCC(ret) && idx < tablet_ls_pair_array.count(); ++idx) {
           ObTabletLSPair &pair = tablet_ls_pair_array.at(idx);
@@ -189,6 +195,13 @@ int ObTabletLSPairCache::rebuild_map_by_tablet_cnt()
     if (OB_FAIL(ObTabletToLSTableOperator::get_tablet_ls_pairs_cnt(*GCTX.sql_proxy_, tenant_id_, tablet_cnt))) {
       LOG_WARN("failed to get tablet_ls pair cnt", KR(ret));
     }
+#ifdef ERRSIM
+    if (OB_FAIL(ret)) {
+    } else if (OB_UNLIKELY(EN_COMPACTION_SKIP_CREATE_MAP)) {
+      tablet_cnt = 0;
+      LOG_INFO("ERRSIM EN_COMPACTION_SKIP_CREATE_MAP, set tablet_cnt to 0", K(tablet_cnt));
+    }
+#endif
   } else {
     tablet_cnt = map_.size();
   }
@@ -237,7 +250,7 @@ int ObTabletLSPairCache::try_refresh(const bool force_refresh/* = false*/)
   share::ObTransferTaskID tmp_max_task_id;
   if (OB_FAIL(check_exist_new_transfer_task(exist, tmp_max_task_id))) {
     LOG_WARN("failed to check transfer task", KR(ret));
-  } else if (force_refresh && OB_FAIL(rebuild_map_by_tablet_cnt())) {
+  } else if ((force_refresh || !map_.created()) && OB_FAIL(rebuild_map_by_tablet_cnt())) {
     LOG_WARN("failed to rebuild map by tablet cnt", KR(ret), K(force_refresh));
   } else if (force_refresh
       || (exist && (ObTimeUtility::fast_current_time() - last_refresh_ts_ >= REFRESH_CACHE_TIME_INTERVAL))) {