From 5d23df100c1e9d9073679d4039c544d61b6e4d30 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 30 Aug 2023 19:07:06 +0800 Subject: [PATCH] fix(stream): ignore the fill-history tasks. --- source/dnode/vnode/src/tq/tqRestore.c | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tqRestore.c b/source/dnode/vnode/src/tq/tqRestore.c index d2419009bf..9929c3e15e 100644 --- a/source/dnode/vnode/src/tq/tqRestore.c +++ b/source/dnode/vnode/src/tq/tqRestore.c @@ -75,7 +75,12 @@ int32_t tqSetStreamTasksReady(STQ* pTq) { for (int32_t i = 0; i < numOfTasks; ++i) { SStreamTaskId* pTaskId = taosArrayGet(pTaskList, i); SStreamTask* pTask = streamMetaAcquireTask(pMeta, pTaskId->streamId, pTaskId->taskId); - if (pTask == NULL || pTask->info.fillHistory == 1) { + if (pTask == NULL) { + continue; + } + + if (pTask->info.fillHistory == 1) { + streamMetaReleaseTask(pMeta, pTask); continue; }