diff --git a/source/libs/stream/src/streamStart.c b/source/libs/stream/src/streamStart.c
index b060121680..c386a49e2d 100644
--- a/source/libs/stream/src/streamStart.c
+++ b/source/libs/stream/src/streamStart.c
@@ -401,6 +401,7 @@ int32_t streamProcessCheckRsp(SStreamTask* pTask, const SStreamTaskCheckRsp* pRs
             "s-task:%s downstream taskId:0x%x (vgId:%d) vnode-transfer/leader-change detected, not send check again, "
             "roll-back needed",
             id, pRsp->downstreamTaskId, pRsp->downstreamNodeId);
+        return 0;
       }
 
       STaskRecheckInfo* pInfo = createRecheckInfo(pTask, pRsp);