diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index f27e7e6316..269e00bc01 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -415,6 +415,7 @@ static int32_t streamTransferStateToStreamTask(SStreamTask* pTask) {
   // free it and remove it from disk meta-store
   streamMetaUnregisterTask(pMeta, pTask->id.taskId);
   streamMetaRemoveTask(pMeta, taskId);
+  streamMetaReleaseTask(pMeta, pTask);
 
   // save to disk
   taosWLockLatch(&pMeta->lock);