diff --git a/source/dnode/vnode/src/vnd/vnodeSync.c b/source/dnode/vnode/src/vnd/vnodeSync.c
index 9a4dfc8c11..42acdd2b40 100644
--- a/source/dnode/vnode/src/vnd/vnodeSync.c
+++ b/source/dnode/vnode/src/vnd/vnodeSync.c
@@ -551,13 +551,13 @@ static void vnodeRestoreFinish(const SSyncFSM *pFsm, const SyncIndex commitIdx)
   walApplyVer(pVnode->pWal, commitIdx);
   pVnode->restored = true;
 
-  if (!pVnode->pTq->pStreamMeta->taskWillbeLaunched) {
+  if (pVnode->pTq->pStreamMeta->taskWillbeLaunched) {
     vInfo("vgId:%d, sync restore finished, stream tasks will be launched by other thread", vgId);
     return;
   }
 
   taosWLockLatch(&pVnode->pTq->pStreamMeta->lock);
-  if (!pVnode->pTq->pStreamMeta->taskWillbeLaunched) {
+  if (pVnode->pTq->pStreamMeta->taskWillbeLaunched) {
     vInfo("vgId:%d, sync restore finished, stream tasks will be launched by other thread", vgId);
     taosWUnLockLatch(&pVnode->pTq->pStreamMeta->lock);
     return;
diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index fb30b6917e..ed3edec805 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -793,11 +793,14 @@ void metaHbToMnode(void* param, void* tmrId) {
   }
 
   if (!enoughTimeDuration(&pMeta->hbInfo)) {
+    qInfo("vgId:%d not enough time, %d", pMeta->vgId, pMeta->hbInfo.tickCounter);
     taosTmrReset(metaHbToMnode, META_HB_CHECK_INTERVAL, param, streamEnv.timer, &pMeta->hbInfo.hbTmr);
     taosReleaseRef(streamMetaId, rid);
     return;
   }
 
+  qInfo("vgId:%d start hb", pMeta->vgId);
+
   taosRLockLatch(&pMeta->lock);
   int32_t numOfTasks = streamMetaGetNumOfTasks(pMeta);
 
@@ -819,7 +822,7 @@ void metaHbToMnode(void* param, void* tmrId) {
     STaskStatusEntry entry = {.streamId = pId->streamId, .taskId = pId->taskId, .status = (*pTask)->status.taskStatus};
     taosArrayPush(hbMsg.pTaskStatus, &entry);
 
-    if (i == 0) {
+    if (!hasValEpset) {
       epsetAssign(&epset, &(*pTask)->info.mnodeEpset);
       hasValEpset = true;
     }
@@ -865,6 +868,8 @@ void metaHbToMnode(void* param, void* tmrId) {
 
     qDebug("vgId:%d, build and send hb to mnode", pMeta->vgId);
     tmsgSendReq(&epset, &msg);
+  } else {
+    qError("vgId:%d no mnd epset", pMeta->vgId);
   }
 
   taosArrayDestroy(hbMsg.pTaskStatus);