fix mem leak

This commit is contained in:
Liu Jicong 2022-12-08 00:39:07 +08:00
parent 440556f46d
commit df251e9750
1 changed files with 3 additions and 0 deletions

View File

@ -947,6 +947,7 @@ void tqSinkToTablePipeline2(SStreamTask* pTask, void* vnode, int64_t ver, void*
} }
taosArrayPush(pReq->aSubmitTbData, pTbData); taosArrayPush(pReq->aSubmitTbData, pTbData);
taosMemoryFree(pTbData);
// encode // encode
int32_t code; int32_t code;
@ -978,10 +979,12 @@ void tqSinkToTablePipeline2(SStreamTask* pTask, void* vnode, int64_t ver, void*
} }
} }
_end: _end:
taosArrayDestroy(createTbArray);
taosArrayDestroy(tagArray); taosArrayDestroy(tagArray);
taosArrayDestroy(pVals); taosArrayDestroy(pVals);
// TODO: change // TODO: change
tDestroySSubmitReq2(pReq, TSDB_MSG_FLG_ENCODE); tDestroySSubmitReq2(pReq, TSDB_MSG_FLG_ENCODE);
taosMemoryFree(pReq);
} }
#if 0 #if 0