Skip to content

Commit

Permalink
[pipeline](fix) Fix blocking task which is not triggered by 2nd RPC (a…
Browse files Browse the repository at this point in the history
…pache#38568)

Once a query is cancelled due to any reason, BE may not receive 2nd RPC
from FE. If so, we must ensure the execution dependency is ready so
tasks will not be blocked.
  • Loading branch information
Gabriel39 authored and feiniaofeiafei committed Aug 9, 2024
1 parent b3df1ba commit 297cd67
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions be/src/pipeline/pipeline_task.h
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,7 @@ class PipelineTask {
bool is_finalized() const { return _finalized; }

void clear_blocking_state() {
_state->get_query_ctx()->get_execution_dependency()->set_always_ready();
// We use a lock to assure all dependencies are not deconstructed here.
std::unique_lock<std::mutex> lc(_dependency_lock);
if (!_finalized) {
Expand Down

0 comments on commit 297cd67

Please sign in to comment.