This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 3e5255a8623 [pipeline](fix) Fix blocking task which is not triggered
by 2nd RPC (… (#38694)
3e5255a8623 is described below
commit 3e5255a862309aadbd893f3ac62fbbefd4229faf
Author: Gabriel <gabrielleeb...@gmail.com>
AuthorDate: Thu Aug 1 18:23:41 2024 +0800
[pipeline](fix) Fix blocking task which is not triggered by 2nd RPC (…
(#38694)
…#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.
---
be/src/pipeline/pipeline_x/pipeline_x_task.h | 1 +
1 file changed, 1 insertion(+)
diff --git a/be/src/pipeline/pipeline_x/pipeline_x_task.h
b/be/src/pipeline/pipeline_x/pipeline_x_task.h
index ae89fe2cdde..47746b76fb0 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_task.h
+++ b/be/src/pipeline/pipeline_x/pipeline_x_task.h
@@ -139,6 +139,7 @@ public:
int task_id() const { return _index; };
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 (!_finished) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
