From fc4caa23b5fb1221a83c63e7d7ebe07b911e8af5 Mon Sep 17 00:00:00 2001
From: factosea <285808407@qq.com>
Date: Mon, 26 Feb 2024 13:52:10 +0800
Subject: [PATCH] fix: cache

---
 source/libs/executor/src/executor.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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