From 111481cef94589e1dca804d08828b0813bb94cd6 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Tue, 1 Aug 2023 08:09:10 +0000
Subject: [PATCH] fix state mem leak

---
 source/libs/stream/src/streamBackendRocksdb.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 8534f3b0a1..f6161a4767 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -1625,9 +1625,11 @@ int32_t streamStateSessionGetKVByCur_rocksdb(SStreamStateCur* pCur, SSessionKey*
   if (pVLen != NULL) *pVLen = len;
 
   if (pKTmp->opNum != pCur->number) {
+    taosMemoryFree(val);
     return -1;
   }
   if (pKey->groupId != 0 && pKey->groupId != pKTmp->key.groupId) {
+    taosMemoryFree(val);
     return -1;
   }
   *pKey = pKTmp->key;