From 30358f1297ac81a04559db4e983f9b84cadf063f Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 22 Jan 2025 12:52:30 +0800 Subject: [PATCH] fix(stream): fix error in check node update trans. --- source/dnode/mnode/impl/src/mndStreamTrans.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndStreamTrans.c b/source/dnode/mnode/impl/src/mndStreamTrans.c index 9ef27f53b8..c0d3a11506 100644 --- a/source/dnode/mnode/impl/src/mndStreamTrans.c +++ b/source/dnode/mnode/impl/src/mndStreamTrans.c @@ -300,9 +300,10 @@ bool isNodeUpdateTransActive() { while ((pIter = taosHashIterate(execInfo.transMgmt.pDBTrans, pIter)) != NULL) { SStreamTransInfo *pTransInfo = (SStreamTransInfo *)pIter; - if (strcmp(pTransInfo->name, MND_STREAM_CHKPT_UPDATE_NAME) != 0) { + if (strcmp(pTransInfo->name, MND_STREAM_CHKPT_UPDATE_NAME) == 0) { mDebug("stream:0x%" PRIx64 " %s st:%" PRId64 " is in task nodeEp update, create new stream not allowed", - pTransInfo->streamId, pTransInfo->name, pTransInfo->startTime) exist = true; + pTransInfo->streamId, pTransInfo->name, pTransInfo->startTime); + exist = true; } }