diff --git a/src/tsdb/src/tsdbCommitQueue.c b/src/tsdb/src/tsdbCommitQueue.c
index 4fdd99dddabaf332bf0ffe1bba6dd963fc27361b..c86b8f32b7ff6bfb30e7b734c7b38504200e44e6 100644
--- a/src/tsdb/src/tsdbCommitQueue.c
+++ b/src/tsdb/src/tsdbCommitQueue.c
@@ -155,5 +155,6 @@ void tsdbIncCommitRef(int vgId) {
 
 void tsdbDecCommitRef(int vgId) {
   int refCount = atomic_sub_fetch_32(&tsCommitQueue.refCount, 1);
+  pthread_cond_broadcast(&(tsCommitQueue.queueNotEmpty));
   tsdbDebug("vgId:%d, dec commit queue ref to %d", vgId, refCount);
 }
\ No newline at end of file