diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index 3314798d6d9599ae1db72d4a84e08b56ecff9e08..efdc644f2c8637a48b78f122ab847603609dd3f8 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2440,7 +2440,7 @@ static void doSendQueryReqs(SSchedMsg* pSchedMsg) {
     SRetrieveSupport* pSupport = pSub->param;
 
     tscDebug("0x%"PRIx64" sub:0x%"PRIx64" launch subquery, orderOfSub:%d.", pSql->self, pSub->self, pSupport->subqueryIndex);
-    tscProcessSql(pSub);
+    tscBuildAndSendRequest(pSub, NULL);
   }
 
   tfree(p);