diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c
index cb313b7eed..7df8bdf891 100644
--- a/source/dnode/vnode/src/tq/tqStreamTask.c
+++ b/source/dnode/vnode/src/tq/tqStreamTask.c
@@ -91,10 +91,13 @@ int32_t tqStartStreamTask(STQ* pTq) {
       continue;
     }
 
-    if (pTask->status.downstreamReady == 1 && HAS_RELATED_FILLHISTORY_TASK(pTask)) {
-      tqDebug("s-task:%s downstream ready, no need to check downstream, check only related fill-history task",
-              pTask->id.idStr);
-      streamLaunchFillHistoryTask(pTask);
+    if (pTask->status.downstreamReady == 1) {
+      if (HAS_RELATED_FILLHISTORY_TASK(pTask)) {
+        tqDebug("s-task:%s downstream ready, no need to check downstream, check only related fill-history task",
+                pTask->id.idStr);
+        streamLaunchFillHistoryTask(pTask);
+      }
+
       streamMetaReleaseTask(pMeta, pTask);
       continue;
     }