diff --git a/source/dnode/vnode/src/sma/smaRollup.c b/source/dnode/vnode/src/sma/smaRollup.c
index 665610304c..424a9b1cf2 100644
--- a/source/dnode/vnode/src/sma/smaRollup.c
+++ b/source/dnode/vnode/src/sma/smaRollup.c
@@ -1221,6 +1221,10 @@ _checkpoint:
 
           smaInfo("vgId:%d, rsma commit, succeed to commit checkpoint/task:%" PRIi64 "/%p, table:%" PRIi64 ", level:%d",
                   TD_VID(pVnode), pTask->checkpointingId, pTask, pRSmaInfo->suid, i + 1);
+
+          // the stream states share one checkpoint
+          taosHashCancelIterate(pInfoHash, infoHash);
+          goto _exit;
         }
       }
     }
diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c
index e38ba85f62..fc47498a3c 100644
--- a/source/libs/stream/src/tstreamFileState.c
+++ b/source/libs/stream/src/tstreamFileState.c
@@ -201,7 +201,7 @@ SStreamFileState* streamFileStateInit(int64_t memSize, uint32_t keySize, uint32_
     streamFileStateDecode(&pFileState->flushMark, valBuf, len);
     qDebug("===stream===flushMark  read:%" PRId64, pFileState->flushMark);
   }
-
+  taosMemoryFreeClear(valBuf);
   return pFileState;
 
 _error: