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

refactor(stream): idle for 100ms when starting next round scan wal.

This commit is contained in:
Haojun Liao 2023-10-04 23:33:03 +08:00
parent 41ef1a45c1
commit 5bf8d16ee1
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/dnode/vnode/src/tq/tqStreamTask.c
View File

@ -50,8 +50,9 @@ int32_t tqScanWal(STQ* pTq) {
taosWUnLockLatch(&pMeta->lock); taosWUnLockLatch(&pMeta->lock);
tqDebug("vgId:%d scan wal for stream tasks for %d times in %dms", vgId, times, SCAN_WAL_IDLE_DURATION); tqDebug("vgId:%d scan wal for stream tasks for %d times in %dms", vgId, times, SCAN_WAL_IDLE_DURATION);
taosMsleep(SCAN_WAL_IDLE_DURATION);
} }
taosMsleep(SCAN_WAL_IDLE_DURATION);
} }
int64_t el = (taosGetTimestampMs() - st); int64_t el = (taosGetTimestampMs() - st);