xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(stream): reset the counter.

This commit is contained in:
Haojun Liao 2023-08-30 20:20:20 +08:00
parent fd2f988cdb
commit a2c6e4306a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/vnode/src/tq/tqRestore.c
View File

@ -149,7 +149,7 @@ int32_t tqStartStreamTasks(STQ* pTq, bool ckPause) {
int32_t numOfPauseTasks = pTq->pStreamMeta->pauseTaskNum; int32_t numOfPauseTasks = pTq->pStreamMeta->pauseTaskNum;
if (ckPause && numOfTasks == numOfPauseTasks) { if (ckPause && numOfTasks == numOfPauseTasks) {
tqDebug("vgId:%d ignore all submit, all streams had been paused", vgId); tqDebug("vgId:%d ignore all submit, all streams had been paused, reset the walScanCounter", vgId);
// reset the counter value, since we do not launch the scan wal operation. // reset the counter value, since we do not launch the scan wal operation.
pMeta->walScanCounter = 0; pMeta->walScanCounter = 0;