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 f1846c10a1c [fix](stop)fix missing notify_all() after the stop (#27796)
f1846c10a1c is described below
commit f1846c10a1cd8b621cec3a52d3e5b052b136d5ce
Author: Mryange <[email protected]>
AuthorDate: Thu Nov 30 16:04:13 2023 +0800
[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 3fd1489103d..16e98f11b28 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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
