add test

streamnative · Nov 9, 2024 · 57ab26d · 57ab26d
1 parent 0efd293
commit 57ab26d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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