From 7cce53f7e539d1f0c830b25dc2c79a2a47ba6bba Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 24 Oct 2023 11:38:14 +0800 Subject: [PATCH] fix(stream): ignore the check status when is ready. --- source/dnode/vnode/src/tq/tqStreamTask.c | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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; }