From 5d021bd65f350ff058924fe41538cf434dbec22a Mon Sep 17 00:00:00 2001 From: husharp Date: Thu, 21 Sep 2023 18:46:06 +0800 Subject: [PATCH] fix Signed-off-by: husharp --- server/cluster/cluster_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/cluster/cluster_test.go b/server/cluster/cluster_test.go index 692a388f2981..0422519dd13f 100644 --- a/server/cluster/cluster_test.go +++ b/server/cluster/cluster_test.go @@ -3111,8 +3111,9 @@ func TestPersistScheduler(t *testing.T) { // whether the schedulers added or removed in dynamic way are recorded in opt _, newOpt, err := newTestScheduleConfig() re.NoError(err) - _, err = schedulers.CreateSchedulerWithoutSave(schedulers.ShuffleRegionType, oc, storage, schedulers.ConfigJSONDecoder([]byte("null"))) + shuffle, err := schedulers.CreateSchedulerWithoutSave(schedulers.ShuffleRegionType, oc, storage, schedulers.ConfigJSONDecoder([]byte("null"))) re.NoError(err) + re.NoError(controller.AddScheduler(storage, shuffle)) // suppose we add a new default enable scheduler sc.DefaultSchedulers = append(sc.DefaultSchedulers, sc.SchedulerConfig{Type: "shuffle-region"}) defer func() {