diff --git a/source/dnode/vnode/src/tq/tqStreamTaskSnap.c b/source/dnode/vnode/src/tq/tqStreamTaskSnap.c
index bc687792296a1544748a8c9fd5d7f7500192d32f..2bd975a0d626f49e974e1a8e69f8d4a76b6e652e 100644
--- a/source/dnode/vnode/src/tq/tqStreamTaskSnap.c
+++ b/source/dnode/vnode/src/tq/tqStreamTaskSnap.c
@@ -119,8 +119,7 @@ NextTbl:
     break;
   }
   if (except == 1) {
-    if (pReader->pos + 1 >= taosArrayGetSize(pReader->tdbTbList)) {
-    } else {
+    if (pReader->pos + 1 < taosArrayGetSize(pReader->tdbTbList)) {
       tdbTbcClose(pReader->pCur);
 
       pReader->pos += 1;