diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index a6ecd7f648..08e7c97150 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -958,6 +958,8 @@ void streamMetaLoadAllTasks(SStreamMeta* pMeta) {
           pMeta->numOfStreamTasks, pMeta->numOfPausedTasks);
 
   taosArrayDestroy(pRecycleList);
+
+  (void)streamMetaCommit(pMeta);
 }
 
 static bool waitForEnoughDuration(SMetaHbInfo* pInfo) {
@@ -1743,4 +1745,4 @@ void streamMetaClearUpdateTaskList(SStreamMeta* pMeta) {
 void streamMetaInitUpdateTaskList(SStreamMeta* pMeta, int32_t transId) {
   taosHashClear(pMeta->updateInfo.pTasks);
   pMeta->updateInfo.transId = transId;
-}
\ No newline at end of file
+}