From 9a1a8feec20f8ad81b5b64f81b7b92068e73bf62 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 24 Oct 2023 15:49:50 +0800 Subject: [PATCH] fix(stream): do send check info if downstream is not leader. --- source/libs/stream/src/streamStart.c | 1 + 1 file changed, 1 insertion(+) 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);