This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new e8fc4563d76 [bugfix](use after free) should not set finish depdency
any more if task ctx lock failed (#32730)
e8fc4563d76 is described below
commit e8fc4563d76afe617786d854ddf7e72f72923d87
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]
