diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 99e1f44ca54d2e9090c7b173b3002b22ca9033d5..acd9388d073b0a28cc734b283953069b461f5ee2 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -3038,6 +3038,10 @@ void filterRowsInDataBlock(SQueryRuntimeEnv* pRuntimeEnv, SSingleColumnFilterInf
       }
 
       if (!tsBufNextPos(pRuntimeEnv->pTsBuf)) {
+        if (i < (numOfRows - 1)) {
+          all = false;
+        }
+      
         break;
       }
     }