From f1846c10a1cd8b621cec3a52d3e5b052b136d5ce Mon Sep 17 00:00:00 2001
From: Mryange <59914473+Mryange@users.noreply.github.com>
Date: Thu, 30 Nov 2023 16:04:13 +0800
Subject: [PATCH] [fix](stop)fix missing notify_all() after the stop (#27796)

---
 be/src/pipeline/pipeline_x/dependency.h | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/be/src/pipeline/pipeline_x/dependency.h b/be/src/pipeline/pipeline_x/dependency.h
index 3fd1489103..16e98f11b2 100644
--- a/be/src/pipeline/pipeline_x/dependency.h
+++ b/be/src/pipeline/pipeline_x/dependency.h
@@ -225,7 +225,10 @@ struct RuntimeFilterTimerQueue {
         _shutdown = true;
     }
 
-    void stop() { _stop = true; }
+    void stop() {
+        _stop = true;
+        cv.notify_all();
+    }
 
     void wait_for_shutdown() const {
         while (!_shutdown) {