From fd2f988cdb93d344bcb752a0e5999eab13352dd2 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 30 Aug 2023 20:19:51 +0800 Subject: [PATCH] fix(stream): reset the counter. --- source/dnode/vnode/src/tq/tqRestore.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tqRestore.c b/source/dnode/vnode/src/tq/tqRestore.c index 8c3dbf7118..72d8172721 100644 --- a/source/dnode/vnode/src/tq/tqRestore.c +++ b/source/dnode/vnode/src/tq/tqRestore.c @@ -149,7 +149,10 @@ int32_t tqStartStreamTasks(STQ* pTq, bool ckPause) { int32_t numOfPauseTasks = pTq->pStreamMeta->pauseTaskNum; if (ckPause && numOfTasks == numOfPauseTasks) { - tqDebug("ignore all submit, all streams had been paused"); + tqDebug("vgId:%d ignore all submit, all streams had been paused", vgId); + + // reset the counter value, since we do not launch the scan wal operation. + pMeta->walScanCounter = 0; taosWUnLockLatch(&pMeta->lock); return 0; }