fix state mem leak
This commit is contained in:
parent
111481cef9
commit
83468a7710
|
@ -1632,6 +1632,12 @@ int32_t streamStateSessionGetKVByCur_rocksdb(SStreamStateCur* pCur, SSessionKey*
|
||||||
taosMemoryFree(val);
|
taosMemoryFree(val);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (pVal != NULL) {
|
||||||
|
*pVal = (char*)val;
|
||||||
|
} else {
|
||||||
|
taosMemoryFree(val);
|
||||||
|
}
|
||||||
*pKey = pKTmp->key;
|
*pKey = pKTmp->key;
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue