diff --git a/internal/apiserver/service/service.go b/internal/apiserver/service/service.go index 69a161d6..9bf28822 100644 --- a/internal/apiserver/service/service.go +++ b/internal/apiserver/service/service.go @@ -59,16 +59,12 @@ func (s *APIServer) RunHttpServer(logger utilLog.Logger) error { } if s.opts.EnableClusterMode { - if s.opts.ServerId == "" { - return fmt.Errorf("server id is required on cluster mode") - } - if s.opts.ReportHost == "" { return fmt.Errorf("report host is required on cluster mode") } s.DMSController.DMS.ClusterUsecase.SetClusterMode(true) - if err := s.DMSController.DMS.ClusterUsecase.Join(s.opts.ServerId); err != nil { + if err := s.DMSController.DMS.ClusterUsecase.Join(fmt.Sprintf("%d", s.opts.ID)); err != nil { return err }