[CP] [fix] hybrid vector index refresh task memory bloat

Co-authored-by: footka <672528926@qq.com>

Author: 2 people

src/share/vector_index/ob_hybrid_vector_refresh_task.h

@@ -110,6 +110,7 @@ class ObHybridVectorRefreshTask : public ObVecIndexIAsyncTask
   ObHybridVectorRefreshTask() : ObVecIndexIAsyncTask(ObMemAttr(MTL_ID(), "VecIdxASyTask")) {}
   virtual ~ObHybridVectorRefreshTask() {}
   virtual void check_task_free() override {
+    all_finished_ = true;
     ObHybridVectorRefreshTaskCtx *ctx = static_cast<ObHybridVectorRefreshTaskCtx *>(get_task_ctx());
     if (OB_NOT_NULL(ctx)) {
       ctx->check_task_free();

src/share/vector_index/ob_vector_index_async_task_util.cpp

@@ -1071,7 +1071,7 @@ void ObVecIndexAsyncTaskHandler::handle(void *task)
     }
   }
   if (OB_NOT_NULL(async_task)
-      && (async_task->get_task_type() != ObVecIndexAsyncTaskType::OB_VECTOR_ASYNC_HYBRID_VECTOR_EMBEDDING || async_task->get_task_ctx()->task_status_.all_finished_)) {
+      && (async_task->get_task_type() != ObVecIndexAsyncTaskType::OB_VECTOR_ASYNC_HYBRID_VECTOR_EMBEDDING || async_task->all_finished())) {
     handle_ls_process_task_cnt(async_task->get_ls_id(), false);
     dec_async_task_ref();
   }

src/share/vector_index/ob_vector_index_async_task_util.h

@@ -285,7 +285,8 @@ class ObVecIndexIAsyncTask
         old_adapter_(nullptr),
         mem_attr_(mem_attr),
         allocator_(ObMemAttr(MTL_ID(), "VecIdxASyTask")),
-        vid_obj_()
+        vid_obj_(),
+        all_finished_(false)
   {}
   virtual ~ObVecIndexIAsyncTask() {}
   int init(const uint64_t tenant_id, const ObLSID &ls_id, const int task_type,
@@ -294,6 +295,7 @@ class ObVecIndexIAsyncTask
   ObLSID &get_ls_id() { return ls_id_; }
   ObVecIndexAsyncTaskCtx *get_task_ctx() { return ctx_; }
   void set_old_adapter(ObPluginVectorIndexAdaptor* adapter) { old_adapter_ = adapter; }
+  bool all_finished() { return all_finished_; }
   virtual void check_task_free() {}
   virtual int do_work() = 0;
 
@@ -310,6 +312,7 @@ class ObVecIndexIAsyncTask
   ObMemAttr mem_attr_;
   common::ObArenaAllocator allocator_;
   ObObj vid_obj_;
+  bool all_finished_;
   DISALLOW_COPY_AND_ASSIGN(ObVecIndexIAsyncTask);
 };