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

Fix(cfg):only write sdb on leader.

This commit is contained in:
xiao-77 2024-12-17 09:50:18 +08:00
parent 0100741409
commit 6eb183a032
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -18,6 +18,7 @@
#include "mndConfig.h" #include "mndConfig.h"
#include "mndDnode.h" #include "mndDnode.h"
#include "mndPrivilege.h" #include "mndPrivilege.h"
#include "mndSync.h"
#include "mndTrans.h" #include "mndTrans.h"
#include "mndUser.h" #include "mndUser.h"
#include "tutil.h" #include "tutil.h"
@ -340,11 +341,15 @@ _OVER:
} }
int32_t mndTryRebuildCfg(SMnode *pMnode) { int32_t mndTryRebuildCfg(SMnode *pMnode) {
if (!mndIsLeader(pMnode)) {
return TSDB_CODE_SUCCESS;
}
int32_t code = 0; int32_t code = 0;
int32_t sz = -1; int32_t sz = -1;
STrans *pTrans = NULL; STrans *pTrans = NULL;
SAcctObj *vObj = NULL, *obj = NULL; SAcctObj *vObj = NULL, *obj = NULL;
SArray *addArray = NULL; SArray *addArray = NULL;
vObj = sdbAcquire(pMnode->pSdb, SDB_CFG, "tsmmConfigVersion"); vObj = sdbAcquire(pMnode->pSdb, SDB_CFG, "tsmmConfigVersion");
if (vObj == NULL) { if (vObj == NULL) {
if ((code = mndInitWriteCfg(pMnode)) < 0) goto _exit; if ((code = mndInitWriteCfg(pMnode)) < 0) goto _exit;