diff --git a/source/libs/sync/src/syncMain.c b/source/libs/sync/src/syncMain.c index 617b141fef..f200212538 100644 --- a/source/libs/sync/src/syncMain.c +++ b/source/libs/sync/src/syncMain.c @@ -2458,6 +2458,10 @@ int32_t syncNodeRebuildPeerAndCfg(SSyncNode* ths, SSyncCfg *cfg){ tstrncpy(ths->raftCfg.cfg.nodeInfo[i].nodeFqdn, cfg->nodeInfo[j].nodeFqdn, TSDB_FQDN_LEN); ths->raftCfg.cfg.nodeInfo[i].nodeId = cfg->nodeInfo[j].nodeId; ths->raftCfg.cfg.nodeInfo[i].nodePort = cfg->nodeInfo[j].nodePort; + if((strcmp(ths->myNodeInfo.nodeFqdn, cfg->nodeInfo[j].nodeFqdn) == 0 + && ths->myNodeInfo.nodePort == cfg->nodeInfo[j].nodePort)){ + ths->raftCfg.cfg.myIndex = i; + } i++; } ths->raftCfg.cfg.totalReplicaNum = i;