diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index a27a8a41a1d5c7e2f6e8f1b81063cde24de2beb9..b4fb832b14ae621579ba2837b2726506f60e5136 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2740,6 +2740,7 @@ void tscHandleSubqueryError(SRetrieveSupport *trsupport, SSqlObj *pSql, int numO
       tscDebug("0x%"PRIx64" retry parse sql and send query, prev error: %s, retry:%d", pParentSql->self,
           tstrerror(code), pParentSql->retry);
 
+      tscResetSqlCmd(&userSql->cmd, false);
       code = tsParseSql(userSql, true);
       if (code == TSDB_CODE_TSC_ACTION_IN_PROGRESS) {
         return;
diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index ba533bb03baea5cb444e7b99504cf7ea25747f90..d5323625da1fe6884fcbaf51d8d3da7ad6433a96 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -3775,6 +3775,9 @@ static void tscSubqueryCompleteCallback(void* param, TAOS_RES* tres, int code) {
 
     tscDebug("0x%"PRIx64" retry parse sql and send query, prev error: %s, retry:%d", pParentSql->self,
              tstrerror(code), pParentSql->retry);
+
+    
+    tscResetSqlCmd(&userSql->cmd, false);
     
     code = tsParseSql(userSql, true);
     if (code == TSDB_CODE_TSC_ACTION_IN_PROGRESS) {