diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index df9360f331..c2a9d516c2 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2443,7 +2443,7 @@ static void doSendQueryReqs(SSchedMsg* pSchedMsg) {
   SPair* p = pSchedMsg->msg;
 
   for (int32_t i = p->first; i < p->second; ++i) {
-   if (i == pSql->subState.numOfSub) {
+   if (i >= pSql->subState.numOfSub) {
       tfree(p);
       return;
     }