fix(stream): do send check info if downstream is not leader.

2023-10-24 15:49:50 +08:00 · 2023-10-24 15:49:50 +08:00 · 9a1a8feec2
parent 2493c21ed3
commit 9a1a8feec2
1 changed files with 1 additions and 0 deletions
--- 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);