diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c
index cbf0d38bd9..2534c5e9f0 100644
--- a/source/libs/executor/src/executor.c
+++ b/source/libs/executor/src/executor.c
@@ -648,7 +648,7 @@ int32_t qExecTaskOpt(qTaskInfo_t tinfo, SArray* pResList, uint64_t* useconds, bo
     ASSERT(p->info.rows > 0 || p->info.type == STREAM_CHECKPOINT);
     taosArrayPush(pResList, &p);
 
-    if (current >= rowsThreshold || current >= pRes->info.rows) {
+    if (current >= rowsThreshold) {
       break;
     }