From 9406be9aa681738d78117efb4c47da05f2939b31 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 11 Jun 2024 18:58:16 +0800 Subject: [PATCH] fix(stream): remove invalid reset. --- source/dnode/vnode/src/tqCommon/tqCommon.c | 1 - 1 file changed, 1 deletion(-) diff --git a/source/dnode/vnode/src/tqCommon/tqCommon.c b/source/dnode/vnode/src/tqCommon/tqCommon.c index 44aef4a91e..cabccfc0c8 100644 --- a/source/dnode/vnode/src/tqCommon/tqCommon.c +++ b/source/dnode/vnode/src/tqCommon/tqCommon.c @@ -202,7 +202,6 @@ int32_t tqStreamTaskProcessUpdateReq(SStreamMeta* pMeta, SMsgCb* cb, SRpcMsg* pM } } else { tqDebug("s-task:%s vgId:%d recv trans to update nodeEp from mnode, transId:%d", idstr, vgId, req.transId); - streamMetaInitUpdateTaskList(pMeta, req.transId); } // duplicate update epset msg received, discard this redundant message