From f2e6135967dc55f3218b71da82aa37ed9e80f13d Mon Sep 17 00:00:00 2001
From: dapan1121 <89396746@qq.com>
Date: Fri, 23 Apr 2021 19:04:01 +0800
Subject: [PATCH] fix bug

---
 src/client/src/tscStream.c | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 3ec2c5336a..b751aea364 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -203,6 +203,14 @@ static void tscProcessStreamQueryCallback(void *param, TAOS_RES *tres, int numOf
     tNameExtractFullName(&pTableMetaInfo->name, name);
 
     taosHashRemove(tscTableMetaInfo, name, strnlen(name, TSDB_TABLE_FNAME_LEN));
+
+    tfree(pTableMetaInfo->pTableMeta);
+
+    tscFreeSqlResult(pStream->pSql);
+    tscFreeSubobj(pStream->pSql);    
+    tfree(pStream->pSql->pSubs);
+    pStream->pSql->subState.numOfSub = 0;
+
     pTableMetaInfo->vgroupList = tscVgroupInfoClear(pTableMetaInfo->vgroupList);
 
     tscSetRetryTimer(pStream, pStream->pSql, retryDelay);
-- 
GitLab