From 67f483430e41341ed63ecf91d05bdff5f3f026ad Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 28 Jun 2024 16:25:59 +0800 Subject: [PATCH] fix(stream): reset the status before re-send data. --- source/libs/stream/src/streamDispatch.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamDispatch.c b/source/libs/stream/src/streamDispatch.c index 5595085197..789cb5cbcf 100644 --- a/source/libs/stream/src/streamDispatch.c +++ b/source/libs/stream/src/streamDispatch.c @@ -416,6 +416,7 @@ static void setResendInfo(SDispatchEntry* pEntry, int64_t now) { pEntry->sendTs = now; pEntry->rspTs = -1; pEntry->retryCount += 1; + pEntry->status = TSDB_CODE_SUCCESS; } static void addDispatchEntry(SDispatchMsgInfo* pMsgInfo, int32_t nodeId, int64_t now, bool lock) {