diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c index fb9c64a880393198c62a233625812186b09240ae..b630419fc4f68197194c100aa6b67e1fd6db448e 100644 --- a/source/common/src/tmsg.c +++ b/source/common/src/tmsg.c @@ -4908,7 +4908,6 @@ int32_t tDecodeSRSmaParam(SDecoder *pCoder, SRSmaParam *pRSmaParam) { if (tDecodeI64v(pCoder, &pRSmaParam->watermark[i]) < 0) return -1; if (tDecodeI32v(pCoder, &pRSmaParam->qmsgLen[i]) < 0) return -1; if (pRSmaParam->qmsgLen[i] > 0) { - tDecoderMalloc(pCoder, pRSmaParam->qmsgLen[i]); if (tDecodeBinary(pCoder, (uint8_t **)&pRSmaParam->qmsg[i], NULL) < 0) return -1; // qmsgLen contains len of '\0' } else { pRSmaParam->qmsg[i] = NULL; diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c index 60f430f05836bc1b44d45f50ba8a2fed40c51a2f..fbbe5bc69555c75c67813f589ed12a1932dba827 100644 --- a/source/dnode/vnode/src/vnd/vnodeSvr.c +++ b/source/dnode/vnode/src/vnd/vnodeSvr.c @@ -437,14 +437,10 @@ static int32_t vnodeProcessCreateStbReq(SVnode *pVnode, int64_t version, void *p goto _err; } - // taosMemoryFree(req.schemaRow.pSchema); - // taosMemoryFree(req.schemaTag.pSchema); tDecoderClear(&coder); return 0; _err: - taosMemoryFree(req.schemaRow.pSchema); - taosMemoryFree(req.schemaTag.pSchema); tDecoderClear(&coder); return -1; }