From 9c9cd08e2ecf30d95a2422cdead25a4200d73eb9 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 25 Oct 2023 00:32:46 +0800 Subject: [PATCH] fix(stream): not clear role flag. --- source/libs/stream/src/streamMeta.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index c536d01516..f2dba090cf 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -230,9 +230,9 @@ _err: int32_t streamMetaReopen(SStreamMeta* pMeta) { streamMetaClear(pMeta); + // NOTE: role should not be changed during reopen meta pMeta->streamBackendRid = -1; pMeta->streamBackend = NULL; - pMeta->role = NODE_ROLE_UNINIT; char* defaultPath = taosMemoryCalloc(1, strlen(pMeta->path) + 128); sprintf(defaultPath, "%s%s%s", pMeta->path, TD_DIRSEP, "state"); @@ -858,7 +858,7 @@ void metaHbToMnode(void* param, void* tmrId) { // not leader not send msg if (pMeta->role != NODE_ROLE_LEADER) { - stInfo("vgId:%d follower not send hb to mnode", pMeta->vgId); + stInfo("vgId:%d role:%d not leader not send hb to mnode", pMeta->vgId, pMeta->role); taosReleaseRef(streamMetaId, rid); pMeta->pHbInfo->hbStart = 0; return;