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) {