diff --git a/coordinator/impl/coordinator_e2e_test.go b/coordinator/impl/coordinator_e2e_test.go index 6043b8b9..97d6a0e0 100644 --- a/coordinator/impl/coordinator_e2e_test.go +++ b/coordinator/impl/coordinator_e2e_test.go @@ -813,6 +813,11 @@ func TestCoordinator_RefreshServerInfo(t *testing.T) { }) } + // check if the new config will trigger node swap + status := c.ClusterStatus() + actions := rebalanceCluster(clusterServer, &status) + assert.EqualValues(t, 0, len(actions)) + clusterConfig.Servers = clusterServer configChangesCh <- nil