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;
     }