From 9f2c448e36eb3b7202bff7b6e38855b4b580a0e6 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 22 Jan 2025 14:05:40 +0800 Subject: [PATCH] fix(stream): fix error in check node update trans. --- source/dnode/mnode/impl/src/mndStreamTrans.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/mnode/impl/src/mndStreamTrans.c b/source/dnode/mnode/impl/src/mndStreamTrans.c index c0d3a11506..fe3359dc74 100644 --- a/source/dnode/mnode/impl/src/mndStreamTrans.c +++ b/source/dnode/mnode/impl/src/mndStreamTrans.c @@ -300,7 +300,7 @@ 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_TASK_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;