提交 1a8a834a 编写于 作者: H Haojun Liao

fix(tmq): fix memory leak.

上级 09a04052
......@@ -341,6 +341,8 @@ int32_t tqNextBlockInWal(STqReader* pReader) {
SDecoder decoder = {0};
tDecoderInit(&decoder, pBody, bodyLen);
taosArrayDestroy(pReader->submit.aSubmitTbData);
if (tDecodeSubmitReq(&decoder, &pReader->submit) < 0) {
tDecoderClear(&decoder);
tqError("decode wal file error, msgLen:%d, ver:%"PRId64, bodyLen, ver);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册