This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit ae3542f552fc4da7e161e6db85f1328ddadd7731 Author: yiguolei <[email protected]> AuthorDate: Sun Mar 24 21:04:48 2024 +0800 [bugfix](use after free) should not set finish depdency any more if task ctx lock failed (#32730) Co-authored-by: yiguolei <[email protected]> --- 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 a961383600c..379261266ea 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); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
