diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c index 94483b8a64..44a3f27983 100644 --- a/source/common/src/tmsg.c +++ b/source/common/src/tmsg.c @@ -5954,6 +5954,7 @@ int32_t tDecodeSMqDataRsp(SDecoder *pDecoder, SMqDataRsp *pRsp) { if (pSW == NULL) return -1; if (tDecodeSSchemaWrapper(pDecoder, pSW) < 0) return -1; taosArrayPush(pRsp->blockSchema, &pSW); + taosMemoryFree(pSW); } if (pRsp->withTbName) {