diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index 1fbe1c8d600afbdaca8b5836d932c83f76c9c863..094b2ab62101c9e8ef56da2790a84899af8fc20b 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2436,7 +2436,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;
     }