Skip to content

Commit ea66579

Browse files
obdevfootka
authored andcommitted
[CP] [fix] hybrid vector index refresh core at deconstruct embedding task
Co-authored-by: footka <672528926@qq.com>
1 parent cd0382c commit ea66579

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

src/share/vector_index/ob_hybrid_vector_refresh_task.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -227,6 +227,9 @@ int ObHybridVectorRefreshTask::do_work()
227227
}
228228
}
229229

230+
if (OB_FAIL(ret) || current_status() == ObHybridVectorRefreshTaskStatus::TASK_FINISH) {
231+
check_task_free();
232+
}
230233
if (OB_NOT_NULL(ctx_)) {
231234
common::ObSpinLockGuard ctx_guard(ctx_->lock_);
232235
ctx_->task_status_.ret_code_ = ret;
@@ -235,9 +238,6 @@ int ObHybridVectorRefreshTask::do_work()
235238
ret = OB_ERR_UNEXPECTED;
236239
LOG_ERROR("unexpected error: null context pointer", K(ret), KPC(this));
237240
}
238-
if (OB_FAIL(ret) || current_status() == ObHybridVectorRefreshTaskStatus::TASK_FINISH) {
239-
check_task_free();
240-
}
241241
return ret;
242242
}
243243

src/share/vector_index/ob_hybrid_vector_refresh_task.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ class ObHybridVectorRefreshTask : public ObVecIndexIAsyncTask
119119
all_finished_ = true;
120120
ObHybridVectorRefreshTaskCtx *ctx = static_cast<ObHybridVectorRefreshTaskCtx *>(get_task_ctx());
121121
if (OB_NOT_NULL(ctx)) {
122-
ctx->check_task_free();
122+
ctx->set_task_finish();
123123
}
124124
}
125125
virtual int do_work() override;

0 commit comments

Comments
 (0)