Fix compilation error.

10 years ago · b2ad9a1110
1 changed files with 1 additions and 1 deletions
--- a/go/topology/topology.go
+++ b/go/topology/topology.go
@ -157,7 +157,7 @@ func (t *Topology) ProcessJoinMessage(joinMessage *operation.JoinMessage) {
 	if *joinMessage.IsInit && dn != nil {
 		t.UnRegisterDataNode(dn)
 	}
 	adminPort = *joinMessage.Port
 	adminPort := *joinMessage.Port
 	if joinMessage.AdminPort != nil {
 		adminPort = *joinMessage.AdminPort
 	}