[CP] Fix offline ddl rebuild ivf index failure, drop vec index process stuck issue.

obdev · ob-robot · commit 71a4c6168e2b · 2026-03-13T10:40:30.000Z
diff --git a/deps/oblib/src/lib/utility/ob_tracepoint_def.h b/deps/oblib/src/lib/utility/ob_tracepoint_def.h
@@ -577,6 +577,10 @@ GLOBAL_ERRSIM_POINT_DEF(1199, EN_DISABLE_ENCODESORTKEY_OPT, "Used for disable en
 GLOBAL_ERRSIM_POINT_DEF(1200, EN_ENABLE_NEWSORT_FORCE, "");
 GLOBAL_ERRSIM_POINT_DEF(1201, EN_DISABLE_NEWSORT_FIXED_KEY_OPT, "Used to control whether to turn off the newsort fixed key opt when use encode sortkey");
 
+// vector index 1300 - 1399
+GLOBAL_ERRSIM_POINT_DEF(1300, EN_VEC_INDEX_IVF_ROWKEY_CID_BUILD_ERR, "");
+GLOBAL_ERRSIM_POINT_DEF(1301, EN_VEC_INDEX_IVF_PQ_BUILD_ERR, "");
+
 // Transaction // 2001 - 2100
 // Transaction free route
 GLOBAL_ERRSIM_POINT_DEF(2001, EN_TX_FREE_ROUTE_UPDATE_STATE_ERROR, "");
diff --git a/src/rootserver/ddl_task/ob_drop_vec_ivf_index_task.cpp b/src/rootserver/ddl_task/ob_drop_vec_ivf_index_task.cpp
@@ -462,6 +462,15 @@ int ObDropVecIVFIndexTask::drop_aux_index_table(const share::ObDDLTaskStatus &ne
     ret = OB_ERR_UNEXPECTED;
     LOG_WARN("unexpected ddl task type", K(ret), K(task_type_));
   }
+
+  // state machine processing: directly switch status if success, otherwise retry if failed
+  if (OB_FAIL(ret)) {
+  } else if (OB_FAIL(switch_status(new_status, true, ret))) {
+    LOG_WARN("switch status failed", K(ret), K(new_status), K(task_status_));
+  } else {
+    LOG_INFO("drop_aux_index_table success", K(ret), K(parent_task_id_), K(task_id_), K(*this));
+  }
+
   return ret;
 }
 
@@ -721,6 +730,7 @@ int ObDropVecIVFIndexTask::create_drop_index_task(
     arg.ddl_stmt_str_        = drop_index_sql.string();
     arg.is_add_to_scheduler_ = true;
     arg.task_id_             = task_id_;
+    arg.is_hidden_           = drop_index_arg_.is_hidden_;
     if (OB_FAIL(ObDDLUtil::get_ddl_rpc_timeout(
             index_schema->get_all_part_num() + data_table_schema->get_all_part_num(), ddl_rpc_timeout_us))) {
       LOG_WARN("fail to get ddl rpc timeout", K(ret));
diff --git a/src/rootserver/ddl_task/ob_index_build_task.cpp b/src/rootserver/ddl_task/ob_index_build_task.cpp
@@ -131,7 +131,19 @@ int ObIndexSSTableBuildTask::process()
     ret = OB_ERR_UNEXPECTED;
     LOG_WARN("error unexpected, index schema must not be nullptr", K(ret), K(tenant_id_), K(dest_table_id_));
   } else {
-    if (is_partitioned_local_index_task()) {
+    #ifdef ERRSIM
+      if (OB_SUCC(ret)
+          && (index_schema->is_vec_ivfflat_rowkey_cid_index()
+            || index_schema->is_vec_ivfpq_rowkey_cid_index()
+            || index_schema->is_vec_ivfsq8_rowkey_cid_index())) {
+        ret = OB_E(EventTable::EN_VEC_INDEX_IVF_ROWKEY_CID_BUILD_ERR) OB_SUCCESS;
+        if (OB_FAIL(ret)) {
+          LOG_WARN("errsim ddl execute building the subtask of vector index rowkey cid table failed", KR(ret));
+        }
+      }
+    #endif
+    if (OB_FAIL(ret)) {
+    } else if (is_partitioned_local_index_task()) {
       bool is_oracle_mode = false;
       if (OB_FAIL(ObCompatModeGetter::check_is_oracle_mode_with_table_id(tenant_id_, data_table_id_, is_oracle_mode))) {
         LOG_WARN("check if oracle mode failed", K(ret), K(data_table_id_));
diff --git a/src/share/vector_index/ob_vector_kmeans_ctx.cpp b/src/share/vector_index/ob_vector_kmeans_ctx.cpp
@@ -1294,6 +1294,16 @@ int ObIvfPqBuildHelper::build(const common::ObTableID &table_id, const common::O
   } else if (OB_FAIL(executor_->build(insert_monitor))) {
     LOG_WARN("failed to build clusters", K(ret));
   }
+
+#ifdef ERRSIM
+  if (OB_SUCC(ret)) {
+    ret = OB_E(common::EventTable::EN_VEC_INDEX_IVF_PQ_BUILD_ERR) OB_SUCCESS;
+    if (OB_FAIL(ret)) {
+      LOG_WARN("[ERRSIM] fail to build ivf pq", K(ret));
+    }
+  }
+#endif
+
   return ret;
 }
 
