From ae3542f552fc4da7e161e6db85f1328ddadd7731 Mon Sep 17 00:00:00 2001 From: yiguolei <676222867@qq.com> Date: Sun, 24 Mar 2024 21:04:48 +0800 Subject: [PATCH] [bugfix](use after free) should not set finish depdency any more if task ctx lock failed (#32730) Co-authored-by: yiguolei --- be/src/vec/sink/writer/async_result_writer.cpp | 2 -- 1 file changed, 2 deletions(-) diff --git a/be/src/vec/sink/writer/async_result_writer.cpp b/be/src/vec/sink/writer/async_result_writer.cpp index a961383600..379261266e 100644 --- a/be/src/vec/sink/writer/async_result_writer.cpp +++ b/be/src/vec/sink/writer/async_result_writer.cpp @@ -101,7 +101,6 @@ Status AsyncResultWriter::start_writer(RuntimeState* state, RuntimeProfile* prof RETURN_IF_ERROR(pool_ptr->submit_func([this, state, profile, task_ctx]() { auto task_lock = task_ctx.lock(); if (task_lock == nullptr) { - _set_ready_to_finish(); return; } this->process_block(state, profile); @@ -111,7 +110,6 @@ Status AsyncResultWriter::start_writer(RuntimeState* state, RuntimeProfile* prof [this, state, profile, task_ctx]() { auto task_lock = task_ctx.lock(); if (task_lock == nullptr) { - _set_ready_to_finish(); return; } this->process_block(state, profile);