From 1e696287d868fedc5f4f2324d9d62f870ae29f52 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 29 Oct 2023 02:45:47 +0800 Subject: [PATCH] fix(stream): set the trans exec sequentially. --- source/dnode/mnode/impl/src/mndStream.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 78826a2311..d48accb2f9 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -2111,6 +2111,7 @@ static int32_t mndProcessVgroupChange(SMnode *pMnode, SVgroupChangeInfo *pChange sdbCancelFetch(pSdb, pIter); return terrno; } + mndTransSetSerial(pTrans); } void *p = taosHashGet(pChangeInfo->pDBMap, pStream->targetDb, strlen(pStream->targetDb));