diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index 52bf5d9bfe5957053599ff7844c7efc7f24dc09e..32955bef3c30f5d7161a3a9a4e104754a8e174d7 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2749,6 +2749,7 @@ void tscHandleSubqueryError(SRetrieveSupport *trsupport, SSqlObj *pSql, int numO
       }
 
       doCleanupSubqueries(userSql, userSql->subState.numOfSub);
+      userSql->subState.numOfSub = 0;
 
       pQueryInfo = tscGetQueryInfo(&userSql->cmd);
       executeQuery(userSql, pQueryInfo);
diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index ae78c7a81e8b3226e5d645803f8e4cd480fb8839..098204605a021bdd4aef1fcabc0afc387edb5cc3 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -4934,3 +4934,4 @@ void tscRemoveTableMetaBuf(STableMetaInfo* pTableMetaInfo, uint64_t id) {
   taosHashRemove(tscTableMetaMap, fname, len);
   tscDebug("0x%"PRIx64" remove table meta %s, numOfRemain:%d", id, fname, (int32_t) taosHashGetSize(tscTableMetaMap));
 }
+                                    
\ No newline at end of file