diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 17883f5fb1..064098ed35 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -458,9 +458,6 @@ int32_t streamMetaOpen(const char* path, void* ahandle, FTaskBuild buildTaskFn,
   code = metaRefMgtAdd(pMeta->vgId, pRid);
   TSDB_CHECK_CODE(code, lino, _err);
 
-  code = createMetaHbInfo(pRid, &pMeta->pHbInfo);
-  TSDB_CHECK_CODE(code, lino, _err);
-
   code = bkdMgtCreate(tpath, (SBkdMgt**)&pMeta->bkdChkptMgt);
   TSDB_CHECK_CODE(code, lino, _err);
 
@@ -469,6 +466,9 @@ int32_t streamMetaOpen(const char* path, void* ahandle, FTaskBuild buildTaskFn,
 
   // add refId at the end of initialization function
   pMeta->rid = taosAddRef(streamMetaId, pMeta);
+  code = createMetaHbInfo(pRid, &pMeta->pHbInfo);
+
+  TSDB_CHECK_CODE(code, lino, _err);
 
   *p = pMeta;
   return code;