From 5bf8d16ee102116f2ef140cc50467d65da4bc693 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 4 Oct 2023 23:33:03 +0800 Subject: [PATCH] refactor(stream): idle for 100ms when starting next round scan wal. --- source/dnode/vnode/src/tq/tqStreamTask.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c index 541d52d5b5..3685435e34 100644 --- a/source/dnode/vnode/src/tq/tqStreamTask.c +++ b/source/dnode/vnode/src/tq/tqStreamTask.c @@ -50,8 +50,9 @@ int32_t tqScanWal(STQ* pTq) { taosWUnLockLatch(&pMeta->lock); 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);