From 3c0dbacf37c08c3fda49e9bcc30ef7c56165e4b0 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Fri, 17 May 2024 16:37:40 +0800 Subject: [PATCH] fix:[TS-4716]wait too long if change system time --- source/dnode/vnode/src/tq/tqRead.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c index 0e9f596cb1..9cbe48a0b0 100644 --- a/source/dnode/vnode/src/tq/tqRead.c +++ b/source/dnode/vnode/src/tq/tqRead.c @@ -414,7 +414,7 @@ bool tqNextBlockInWal(STqReader* pReader, const char* id, int sourceExcluded) { pReader->msg.msgStr = NULL; int64_t elapsed = taosGetTimestampMs() - st; - if(elapsed > 1000 && elapsed < 0){ + if(elapsed > 1000 || elapsed < 0){ return false; }