diff --git a/pkg/controllers/cluster/manager/innodb_cluster.go b/pkg/controllers/cluster/manager/innodb_cluster.go index 3b67ea16c..2039cc1b3 100644 --- a/pkg/controllers/cluster/manager/innodb_cluster.go +++ b/pkg/controllers/cluster/manager/innodb_cluster.go @@ -76,7 +76,7 @@ func getReplicationGroupSeeds(seeds string, pod *cluster.Instance) ([]string, er if err != nil { return nil, err } - if seedInstance.PodName() == pod.Name() { + if seedInstance.Name() == pod.Name() { continue } s = append(s, seed) diff --git a/pkg/controllers/cluster/manager/innodb_cluster_test.go b/pkg/controllers/cluster/manager/innodb_cluster_test.go index 6e6bae59e..bc0aa06d0 100644 --- a/pkg/controllers/cluster/manager/innodb_cluster_test.go +++ b/pkg/controllers/cluster/manager/innodb_cluster_test.go @@ -32,11 +32,11 @@ func TestGetReplicationGroupSeeds(t *testing.T) { { seeds: "server-1-0:1234,server-1-1:1234", pod: cluster.NewInstance("", "", "server-1", 0, -1, false), - expected: []string{"server-1-0:1234", "server-1-1:1234"}, + expected: []string{"server-1-1:1234"}, }, { seeds: "server-1-1:1234,server-1-0:1234", pod: cluster.NewInstance("", "", "server-1", 0, -1, false), - expected: []string{"server-1-1:1234", "server-1-0:1234"}, + expected: []string{"server-1-1:1234"}, }, { seeds: "server-1-0:1234,server-1-1:1234", pod: cluster.NewInstance("", "", "server-2", 0, -1, false),