fix invalid free
This commit is contained in:
parent
01e9ae6299
commit
f33bf898b4
|
@ -2740,8 +2740,10 @@ int32_t streamStateGetGroupKVByCur_rocksdb(SStreamStateCur* pCur, SWinKey* pKey,
|
||||||
if (pKey->groupId == groupId) {
|
if (pKey->groupId == groupId) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
if (pVal != NULL) taosMemoryFree((void*)*pVal);
|
if (pVal != NULL) {
|
||||||
*pVal = NULL;
|
taosMemoryFree((void*)*pVal);
|
||||||
|
*pVal = NULL;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue