fix(stream): avoid double free.
This commit is contained in:
parent
878d14052f
commit
b782af2534
|
@ -104,7 +104,6 @@ int32_t streamStateSnapRead(SStreamStateReader* pReader, uint8_t** ppData) {
|
||||||
pHdr->type = SNAP_DATA_STREAM_STATE_BACKEND;
|
pHdr->type = SNAP_DATA_STREAM_STATE_BACKEND;
|
||||||
pHdr->size = len;
|
pHdr->size = len;
|
||||||
memcpy(pHdr->data, rowData, len);
|
memcpy(pHdr->data, rowData, len);
|
||||||
taosMemoryFree(rowData);
|
|
||||||
tqDebug("vgId:%d, vnode stream-state snapshot read data success", TD_VID(pReader->pTq->pVnode));
|
tqDebug("vgId:%d, vnode stream-state snapshot read data success", TD_VID(pReader->pTq->pVnode));
|
||||||
taosMemoryFree(rowData);
|
taosMemoryFree(rowData);
|
||||||
return code;
|
return code;
|
||||||
|
|
Loading…
Reference in New Issue