xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(stream): fix error in check node update trans.

This commit is contained in:
Haojun Liao 2025-01-22 12:52:30 +08:00
parent 2f065062c3
commit 30358f1297
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/dnode/mnode/impl/src/mndStreamTrans.c
View File

@ -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;
}
}