fix mem leak
This commit is contained in:
parent
ed931c1100
commit
3020e27114
|
@ -431,6 +431,8 @@ int64_t streamGetLatestCheckpointId(SStreamMeta* pMeta) {
|
||||||
tDecoderClear(&decoder);
|
tDecoderClear(&decoder);
|
||||||
|
|
||||||
chkpId = TMAX(chkpId, pTask->chkInfo.checkpointId);
|
chkpId = TMAX(chkpId, pTask->chkInfo.checkpointId);
|
||||||
|
|
||||||
|
taosMemoryFree(pTask); // fix mem leak later
|
||||||
}
|
}
|
||||||
|
|
||||||
_err:
|
_err:
|
||||||
|
|
Loading…
Reference in New Issue