From 68d870084659e3f0b544f8aca57a17f911651e75 Mon Sep 17 00:00:00 2001 From: dmchen Date: Thu, 29 Aug 2024 01:02:26 +0000 Subject: [PATCH] fix/TD-31686-fix-case --- source/dnode/mnode/impl/src/mndStream.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 16c1b4cdc4..e466e4c425 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -2163,6 +2163,8 @@ static int32_t refreshNodeListFromExistedStreams(SMnode *pMnode, SArray *pNodeLi SNodeEntry entry = {.hbTimestamp = -1, .nodeId = pTask->info.nodeId, .lastHbMsgId = -1}; epsetAssign(&entry.epset, &pTask->info.epSet); + (void)taosHashPut(pHash, &entry.nodeId, sizeof(entry.nodeId), &entry, sizeof(entry)); + /* if (taosHashPut(pHash, &entry.nodeId, sizeof(entry.nodeId), &entry, sizeof(entry)) == 0) { code = terrno; taosWUnLockLatch(&pStream->lock); @@ -2171,6 +2173,7 @@ static int32_t refreshNodeListFromExistedStreams(SMnode *pMnode, SArray *pNodeLi taosArrayClear(pNodeList); return code; } + */ } destroyStreamTaskIter(pTaskIter);