diff --git a/pkg/cluster/pod.go b/pkg/cluster/pod.go index 1a49fa2dd..3040bc7e9 100644 --- a/pkg/cluster/pod.go +++ b/pkg/cluster/pod.go @@ -141,14 +141,14 @@ func (c *Cluster) recreatePods() error { } if masterPod.Name == "" { c.logger.Warningln("No master pod in the cluster") - } + } else { + //TODO: do manual failover + //TODO: specify master, leave new master empty + c.logger.Infof("Recreating master pod '%s'", util.NameFromMeta(masterPod.ObjectMeta)) - //TODO: do manual failover - //TODO: specify master, leave new master empty - c.logger.Infof("Recreating master pod '%s'", util.NameFromMeta(masterPod.ObjectMeta)) - - if err := c.recreatePod(masterPod); err != nil { - return fmt.Errorf("could not recreate master pod '%s': %v", util.NameFromMeta(masterPod.ObjectMeta), err) + if err := c.recreatePod(masterPod); err != nil { + return fmt.Errorf("could not recreate master pod '%s': %v", util.NameFromMeta(masterPod.ObjectMeta), err) + } } return nil diff --git a/pkg/util/config/config.go b/pkg/util/config/config.go index cd038e9a8..fdfcbc47e 100644 --- a/pkg/util/config/config.go +++ b/pkg/util/config/config.go @@ -79,6 +79,9 @@ func NewFromMap(m map[string]string) *Config { value = structField.Default } + if value == "" { + continue + } err := processField(value, structField.Field) if err != nil { panic(err)