From 103782d4f1cf8640c17b3c22af4f3d6a3f39f8a3 Mon Sep 17 00:00:00 2001
From: Gabriel <gabrielleebuaa@gmail.com>
Date: Mon, 22 Jul 2024 16:21:21 +0800
Subject: [PATCH] [fix](pipeline) Fix blocked tasks if query is canceled before
 openning

---
 be/src/pipeline/pipeline_task.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/be/src/pipeline/pipeline_task.cpp b/be/src/pipeline/pipeline_task.cpp
index 80b23d9401138c..b123c613d722bf 100644
--- a/be/src/pipeline/pipeline_task.cpp
+++ b/be/src/pipeline/pipeline_task.cpp
@@ -120,6 +120,9 @@ Status PipelineTask::prepare(const TPipelineInstanceParams& local_params, const
         std::unique_lock<std::mutex> lc(_dependency_lock);
         filter_dependencies.swap(_filter_dependencies);
     }
+    if (query_context()->is_cancelled()) {
+        clear_blocking_state();
+    }
     return Status::OK();
 }