Update agent.go

wind-c · Jul 31, 2024 · d1e021d · d1e021d
1 parent 2bbdfb0
commit d1e021d
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/cluster/agent.go b/cluster/agent.go
@@ -73,12 +73,9 @@ func NewAgent(conf *config.Cluster) *Agent {
 
 func (a *Agent) Start() (err error) {
 	// setup raft
-	if a.Config.DiscoveryWay == config.DiscoveryWayMemberlist {
+	if a.Config.RaftPort == 0 || a.Config.DiscoveryWay == config.DiscoveryWayMemberlist {
 		a.Config.RaftPort = mlist.GetRaftPortFromBindPort(a.Config.BindPort)
 	}
-	if a.Config.RaftPort == 0 {
-		a.Config.RaftPort = 8946
-	}
 	if a.Config.RaftDir == "" {
 		a.Config.RaftDir = path.Join("data", a.Config.NodeName)
 	}