diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index e52486b85e..bd8227a962 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -431,6 +431,8 @@ int64_t streamGetLatestCheckpointId(SStreamMeta* pMeta) {
     tDecoderClear(&decoder);
 
     chkpId = TMAX(chkpId, pTask->chkInfo.checkpointId);
+
+    taosMemoryFree(pTask);  // fix mem leak later
   }
 
 _err: