From 707fe02885c7b9515a5de2b65376b5e5eda280ab Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 28 Jun 2024 16:30:12 +0800 Subject: [PATCH] fix(stream):set the initial transId --- source/dnode/vnode/src/tqCommon/tqCommon.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tqCommon/tqCommon.c b/source/dnode/vnode/src/tqCommon/tqCommon.c index 624257d4c6..0a7870ec49 100644 --- a/source/dnode/vnode/src/tqCommon/tqCommon.c +++ b/source/dnode/vnode/src/tqCommon/tqCommon.c @@ -171,7 +171,11 @@ int32_t tqStreamTaskProcessUpdateReq(SStreamMeta* pMeta, SMsgCb* cb, SRpcMsg* pM SStreamTask* pTask = *ppTask; const char* idstr = pTask->id.idStr; - if ((pMeta->updateInfo.transId != req.transId) && (pMeta->updateInfo.transId != -1)) { + if (pMeta->updateInfo.transId == -1) { // info needs to be kept till the new trans to update the nodeEp arrived. + streamMetaInitUpdateTaskList(pMeta, req.transId); + } + + if (pMeta->updateInfo.transId != req.transId) { if (req.transId < pMeta->updateInfo.transId) { tqError("s-task:%s vgId:%d disorder update nodeEp msg recv, discarded, newest transId:%d, recv:%d", idstr, vgId, pMeta->updateInfo.transId, req.transId);