Skip to content

Commit

Permalink
[bugfix](use after free) should not set finish depdency any more if t…
Browse files Browse the repository at this point in the history
…ask ctx lock failed (apache#32730)

Co-authored-by: yiguolei <[email protected]>
  • Loading branch information
yiguolei and Doris-Extras authored Mar 24, 2024
1 parent b9c1d05 commit e8fc456
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions be/src/vec/sink/writer/async_result_writer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -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);
Expand Down

0 comments on commit e8fc456

Please sign in to comment.