diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c
index 7c56acbeffdea1b2b5884a5783fef8f83339ea98..cc3bcf514f94e465349597ccb7dfe06a57257484 100644
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -3124,6 +3124,8 @@ void destroyStreamSessionAggOperatorInfo(void* param) {
   tSimpleHashCleanup(pInfo->pStDeleted);
 
   taosArrayDestroy(pInfo->historyWins);
+  blockDataDestroy(pInfo->pCheckpointRes);
+
   taosMemoryFreeClear(param);
 }
 
@@ -4378,6 +4380,8 @@ void destroyStreamStateOperatorInfo(void* param) {
   blockDataDestroy(pInfo->pDelRes);
   taosArrayDestroy(pInfo->historyWins);
   tSimpleHashCleanup(pInfo->pSeDeleted);
+  blockDataDestroy(pInfo->pCheckpointRes);
+
   taosMemoryFreeClear(param);
 }
 
diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index a29ac67cfebba3de65eb62fcce867885009f144f..99bcfd744f07d4ecdfb64d1195804c5f8b6bacc0 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -398,6 +398,7 @@ int32_t delObsoleteCheckpoint(void* arg, const char* path) {
       taosRemoveDir(tbuf);
     }
   }
+  taosArrayDestroy(checkpointDel);
   return 0;
 }
 int32_t streamBackendDoCheckpoint(void* arg, const char* path) {