This is an automated email from the ASF dual-hosted git repository.
gabriellee 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 47f2d6c71d8 [pipeline](fix) Fix blocking task which is not triggered
by 2nd RPC (#38568)
47f2d6c71d8 is described below
commit 47f2d6c71d8ac2b791dbc6a65ac907af0832e8ca
Author: Gabriel <[email protected]>
AuthorDate: Wed Jul 31 19:59:02 2024 +0800
[pipeline](fix) Fix blocking task which is not triggered by 2nd RPC (#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_task.h | 1 +
1 file changed, 1 insertion(+)
diff --git a/be/src/pipeline/pipeline_task.h b/be/src/pipeline/pipeline_task.h
index 63f464c03ad..8fb4b4eb799 100644
--- a/be/src/pipeline/pipeline_task.h
+++ b/be/src/pipeline/pipeline_task.h
@@ -136,6 +136,7 @@ public:
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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
