fix state mem leak

6cdf94fe · dengyihao · d9fd9577 · 6cdf94fe
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

source/libs/stream/src/streamBackendRocksdb.c source/libs/stream/src/streamBackendRocksdb.c +2 -0

未找到文件。
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -1617,6 +1617,8 @@ int32_t streamStateSessionGetKVByCur_rocksdb(SStreamStateCur* pCur, SSessionKey*
  if (len < 0) {
    return -1;
  }
+  if (pVal != NULL) *pVal = NULL;
+  if (pVLen != NULL) *pVLen = 0;
  if (pKTmp->opNum != pCur->number) {
    taosMemoryFree(val);