From 4cd35d76db6d7b6348924a209c70a932cf4b6145 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Thu, 26 Sep 2024 15:51:32 +0800
Subject: [PATCH]  fix mem leak

---
 source/libs/stream/src/tstreamFileState.c | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c
index 9f8523b040..f7a88746ec 100644
--- a/source/libs/stream/src/tstreamFileState.c
+++ b/source/libs/stream/src/tstreamFileState.c
@@ -100,7 +100,7 @@ void* intervalCreateStateKey(SRowBuffPos* pPos, int64_t num) {
     qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
     return NULL;
   }
-  SWinKey*   pWinKey = pPos->pKey;
+  SWinKey* pWinKey = pPos->pKey;
   pStateKey->key = *pWinKey;
   pStateKey->opNum = num;
   return pStateKey;
@@ -120,7 +120,7 @@ void* sessionCreateStateKey(SRowBuffPos* pPos, int64_t num) {
     qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
     return NULL;
   }
-  SSessionKey*      pWinKey = pPos->pKey;
+  SSessionKey* pWinKey = pPos->pKey;
   pStateKey->key = *pWinKey;
   pStateKey->opNum = num;
   return pStateKey;
@@ -734,7 +734,7 @@ void flushSnapshot(SStreamFileState* pFileState, SStreamSnapshot* pSnapshot, boo
     // todo handle failure
     memset(buf, 0, len);
   }
-  taosMemoryFree(buf);
+  taosMemoryFreeClear(buf);
 
   int32_t numOfElems = streamStateGetBatchSize(batch);
   if (numOfElems > 0) {
@@ -769,6 +769,7 @@ _end:
   if (code != TSDB_CODE_SUCCESS) {
     qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
   }
+  taosMemoryFree(buf);
   streamStateDestroyBatch(batch);
 }
 
@@ -850,7 +851,7 @@ int32_t recoverSesssion(SStreamFileState* pFileState, int64_t ckId) {
     if (winRes != TSDB_CODE_SUCCESS) {
       break;
     }
-    
+
     if (vlen != pFileState->rowSize) {
       code = TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR;
       QUERY_CHECK_CODE(code, lino, _end);