From 7052c033e15cf4839a619fcc661140294db72f84 Mon Sep 17 00:00:00 2001
From: YoungYang0820 <youngyang0820@gmail.com>
Date: Thu, 14 Apr 2022 11:19:59 +0800
Subject: [PATCH] fix get data size fail causing index fail

---
 src/storage/ob_build_index_scheduler.cpp | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/storage/ob_build_index_scheduler.cpp b/src/storage/ob_build_index_scheduler.cpp
index 11fbb61ad7..413490d35a 100644
--- a/src/storage/ob_build_index_scheduler.cpp
+++ b/src/storage/ob_build_index_scheduler.cpp
@@ -980,6 +980,7 @@ int ObBuildIndexScheduleTask::send_copy_replica_rpc()
     }
     ret = OB_EAGAIN;
   } else {
+    int tmp_ret = OB_SUCCESS;
     obrpc::ObServerCopyLocalIndexSSTableArg arg;
     ObAddr rs_addr;
     ObSchemaGetterGuard schema_guard;
@@ -990,12 +991,14 @@ int ObBuildIndexScheduleTask::send_copy_replica_rpc()
     arg.pkey_ = pkey_;
     arg.index_table_id_ = index_id_;
     arg.cluster_id_ = GCONF.cluster_id;
+    if (OB_SUCCESS != (tmp_ret = get_data_size(arg.data_size_))) {
+      arg.data_size_ = 0;
+      STORAGE_LOG(INFO, "fail to get data size, will use data table size to estimate", K(tmp_ret));
+    }
     if (arg.data_src_ == arg.dst_) {
       // if the source and destination are the same, it means that this replica builds the index sstable itself,
       // just retry the scheduling process will get the right way to next state
       ret = OB_EAGAIN;
-    } else if (OB_FAIL(get_data_size(arg.data_size_))) {
-      STORAGE_LOG(WARN, "fail to get data size", K(ret));
     } else if (OB_FAIL(ObMultiVersionSchemaService::get_instance().get_tenant_full_schema_guard(
                    extract_tenant_id(index_id_), schema_guard))) {
       STORAGE_LOG(WARN, "fail to get schema guard", K(ret), K(schema_version_));
-- 
GitLab