diff --git a/server/server.go b/server/server.go index 5b1e9494cf96..73e00f6af17a 100644 --- a/server/server.go +++ b/server/server.go @@ -40,6 +40,7 @@ import ( "github.com/pingcap/kvproto/pkg/keyspacepb" "github.com/pingcap/kvproto/pkg/metapb" "github.com/pingcap/kvproto/pkg/pdpb" + "github.com/pingcap/kvproto/pkg/schedulingpb" "github.com/pingcap/kvproto/pkg/tsopb" "github.com/pingcap/log" "github.com/pingcap/sysutil" @@ -1994,7 +1995,7 @@ func (s *Server) initSchedulingPrimaryWatcher() { schedulingRootPath := endpoint.SchedulingSvcRootPath(s.clusterID) schedulingServicePrimaryKey := path.Join(schedulingRootPath, mcs.PrimaryKey) putFn := func(kv *mvccpb.KeyValue) error { - primary := &tsopb.Participant{} // TODO: use Generics + primary := &schedulingpb.Participant{} // TODO: use Generics if err := proto.Unmarshal(kv.Value, primary); err != nil { return err }