diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index aea689c0defc02be4fcc67b5903c3b58edd8811a..3d89aa2f15280b91eddf95f574900e874f35cb0d 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -4996,6 +4996,7 @@ int32_t tDeserializeSMRecoverStreamReq(void *buf, int32_t bufLen, SMRecoverStrea
 }
 
 void tFreeSCMCreateStreamReq(SCMCreateStreamReq *pReq) {
+  taosArrayDestroy(pReq->pTags);
   taosMemoryFreeClear(pReq->sql);
   taosMemoryFreeClear(pReq->ast);
 }