From 9c8039209e1080c22aa1c98703a8b708c46f2431 Mon Sep 17 00:00:00 2001 From: D3Hunter Date: Mon, 19 Feb 2024 15:31:44 +0800 Subject: [PATCH] fix test --- pkg/disttask/importinto/scheduler_testkit_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/disttask/importinto/scheduler_testkit_test.go b/pkg/disttask/importinto/scheduler_testkit_test.go index 9d953d6f21f08..99c26f113f735 100644 --- a/pkg/disttask/importinto/scheduler_testkit_test.go +++ b/pkg/disttask/importinto/scheduler_testkit_test.go @@ -180,6 +180,7 @@ func TestSchedulerExtGlobalSort(t *testing.T) { mgr := storage.NewTaskManager(pool) storage.SetTaskManager(mgr) sch := scheduler.NewManager(util.WithInternalSourceType(ctx, "scheduler"), mgr, "host:port") + require.NoError(t, mgr.InitMeta(ctx, ":4000", "")) // create job conn := tk.Session().(sqlexec.SQLExecutor)