diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 521f08ff8a9f159c5666b39942e5a5f4b8cbfbe4..7fc05c561d78e4b1b0472bd08096f95616b444e3 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -1674,6 +1674,14 @@ SSqlObj* createSimpleSubObj(SSqlObj* pSql, void (*fp)(), void* param, int32_t cm
   pNew->param = param;
   pNew->maxRetry = TSDB_MAX_REPLICA_NUM;
 
+  pNew->sqlstr = strdup(pSql->sqlstr);
+  if (pNew->sqlstr == NULL) {
+    tscError("%p new subquery failed", pSql);
+
+    free(pNew);
+    return NULL;
+  }
+
   SQueryInfo* pQueryInfo = NULL;
   tscGetQueryInfoDetailSafely(pCmd, 0, &pQueryInfo);
 
@@ -1697,6 +1705,14 @@ SSqlObj* createSubqueryObj(SSqlObj* pSql, int16_t tableIndex, void (*fp)(), void
   pNew->pTscObj = pSql->pTscObj;
   pNew->signature = pNew;
 
+  pNew->sqlstr = strdup(pSql->sqlstr);
+  if (pNew->sqlstr == NULL) {
+    tscError("%p new subquery failed, tableIndex:%d, vgroupIndex:%d", pSql, tableIndex, pTableMetaInfo->vgroupIndex);
+
+    free(pNew);
+    return NULL;
+  }
+
   SSqlCmd* pnCmd = &pNew->cmd;
   memcpy(pnCmd, pCmd, sizeof(SSqlCmd));