Skip to content

Commit 42408f1

Browse files
authored
[fix](error) Avoid deadlock if task status is unexpected (#56816)
1 parent 491d628 commit 42408f1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

be/src/pipeline/pipeline_task.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -678,8 +678,8 @@ Status PipelineTask::finalize() {
678678
return Status::OK();
679679
}
680680
SCOPED_SWITCH_THREAD_MEM_TRACKER_LIMITER(fragment->get_query_ctx()->query_mem_tracker());
681-
std::unique_lock<std::mutex> lc(_dependency_lock);
682681
RETURN_IF_ERROR(_state_transition(State::FINALIZED));
682+
std::unique_lock<std::mutex> lc(_dependency_lock);
683683
_sink_shared_state.reset();
684684
_op_shared_states.clear();
685685
_shared_state_map.clear();

0 commit comments

Comments
 (0)