From 65fded4a28ab07c881d2c45fa582a8c08c39b64b Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 20 Apr 2023 19:03:43 +0800 Subject: [PATCH] fix(stream): set the correct number of tasks. --- source/dnode/vnode/src/tq/tqRestore.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/source/dnode/vnode/src/tq/tqRestore.c b/source/dnode/vnode/src/tq/tqRestore.c index 56f0a80b9e..dd5da6b462 100644 --- a/source/dnode/vnode/src/tq/tqRestore.c +++ b/source/dnode/vnode/src/tq/tqRestore.c @@ -89,6 +89,8 @@ int32_t doCreateReqsByScanWal(SStreamMeta* pStreamMeta, STqOffsetStore* pOffsetS tqDebug("vgId:%d start to check wal to extract new submit block for %d tasks", vgId, numOfTasks); SArray* pTaskIdList = extractTaskIdList(pStreamMeta, numOfTasks); + // update the new task number + numOfTasks = taosArrayGetSize(pTaskIdList); for (int32_t i = 0; i < numOfTasks; ++i) { int32_t* pTaskId = taosArrayGet(pTaskIdList, i); SStreamTask* pTask = streamMetaAcquireTask(pStreamMeta, *pTaskId);