diff --git a/manager/config/config.go b/manager/config/config.go index d50d60e4c..d5b52c022 100644 --- a/manager/config/config.go +++ b/manager/config/config.go @@ -567,7 +567,7 @@ func (cfg *Config) Validate() error { func (cfg *Config) Convert() error { // TODO Compatible with deprecated fields host and port. if len(cfg.Database.Redis.Addrs) == 0 && cfg.Database.Redis.Host != "" && cfg.Database.Redis.Port > 0 { - cfg.Database.Redis.Addrs[0] = fmt.Sprintf("%s:%d", cfg.Database.Redis.Host, cfg.Database.Redis.Port) + cfg.Database.Redis.Addrs = []string{fmt.Sprintf("%s:%d", cfg.Database.Redis.Host, cfg.Database.Redis.Port)} } return nil diff --git a/scheduler/config/config.go b/scheduler/config/config.go index ec0651eee..84633d773 100644 --- a/scheduler/config/config.go +++ b/scheduler/config/config.go @@ -497,7 +497,7 @@ func (cfg *Config) Validate() error { func (cfg *Config) Convert() error { // TODO Compatible with deprecated fields host and port. if len(cfg.Job.Redis.Addrs) == 0 && cfg.Job.Redis.Host != "" && cfg.Job.Redis.Port > 0 { - cfg.Job.Redis.Addrs[0] = fmt.Sprintf("%s:%d", cfg.Job.Redis.Host, cfg.Job.Redis.Port) + cfg.Job.Redis.Addrs = []string{fmt.Sprintf("%s:%d", cfg.Job.Redis.Host, cfg.Job.Redis.Port)} } return nil