diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 83fe0b03c0..c398254548 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -759,18 +759,17 @@ static void doClear(void* pKey, void* pVal, TBC* pCur, SArray* pRecycleList) {
 int32_t streamMetaReloadAllTasks(SStreamMeta* pMeta) {
   if (pMeta == NULL) return 0;
 
-  void* pIter = taosHashIterate(pMeta->pTaskBackendUnique, NULL);
-  while (pIter) {
-    STaskBackendWrapper* taskBackend = *(STaskBackendWrapper**)pIter;
-    if (taskBackend != NULL) {
-      taskBackendRemoveRef(taskBackend);
-    }
-    pIter = taosHashIterate(pMeta->pTaskBackendUnique, pIter);
-  }
-  taosHashClear(pMeta->pTaskBackendUnique);
+  // void* pIter = taosHashIterate(pMeta->pTaskBackendUnique, NULL);
+  // while (pIter) {
+  //   STaskBackendWrapper* taskBackend = *(STaskBackendWrapper**)pIter;
+  //   if (taskBackend != NULL) {
+  //     taskBackendRemoveRef(taskBackend);
+  //   }
+  //   pIter = taosHashIterate(pMeta->pTaskBackendUnique, pIter);
+  // }
+  // taosHashClear(pMeta->pTaskBackendUnique);
 
-  
-  return 0;
+  return streamMetaLoadAllTasks(pMeta);
 }
 int32_t streamMetaLoadAllTasks(SStreamMeta* pMeta) {
   TBC* pCur = NULL;