From 12371207300dd8d82a6dbc9c2637ee2b5839e1a0 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 24 Jul 2024 14:31:16 +0800 Subject: [PATCH] fix(stream): ignore error. --- source/dnode/mnode/impl/src/mndStream.c | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index b3e81665e3..2c3f2c59c7 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -2474,10 +2474,7 @@ static int32_t extractNodeListFromStream(SMnode *pMnode, SArray *pNodeList) { SNodeEntry entry = {.hbTimestamp = -1, .nodeId = pTask->info.nodeId}; epsetAssign(&entry.epset, &pTask->info.epSet); - code = taosHashPut(pHash, &entry.nodeId, sizeof(entry.nodeId), &entry, sizeof(entry)); - if (code) { - break; - } + (void)taosHashPut(pHash, &entry.nodeId, sizeof(entry.nodeId), &entry, sizeof(entry)); } destroyStreamTaskIter(pTaskIter);