From 7062f0e02e0696a0a94fe639d0651a963862a595 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sat, 20 Jun 2020 15:50:29 +0800
Subject: [PATCH] [td-225]

---
 src/client/src/tscUtil.c | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 521f08ff8a..7fc05c561d 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));