From 83468a77107b9560849683b8e3989295950882b5 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 2 Aug 2023 03:18:59 +0000 Subject: [PATCH] fix state mem leak --- source/libs/stream/src/streamBackendRocksdb.c | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index f6161a4767..5e08f566d6 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1632,6 +1632,12 @@ int32_t streamStateSessionGetKVByCur_rocksdb(SStreamStateCur* pCur, SSessionKey* taosMemoryFree(val); return -1; } + + if (pVal != NULL) { + *pVal = (char*)val; + } else { + taosMemoryFree(val); + } *pKey = pKTmp->key; return 0; }