diff --git a/federation/pkg/federation-controller/service/servicecontroller.go b/federation/pkg/federation-controller/service/servicecontroller.go index 9cdc911bc07..17911b3d3d7 100644 --- a/federation/pkg/federation-controller/service/servicecontroller.go +++ b/federation/pkg/federation-controller/service/servicecontroller.go @@ -728,8 +728,12 @@ func (s *ServiceController) lockedUpdateDNSRecords(service *cachedService, clust for key := range s.clusterCache.clientMap { for _, clusterName := range clusterNames { if key == clusterName { - s.ensureDnsRecords(clusterName, service) - ensuredCount += 1 + err := s.ensureDnsRecords(clusterName, service) + if err != nil { + glog.Errorf("Failed to ensure DNS records for service %v in cluster %s due to %v", service, clusterName, err) + } else { + ensuredCount += 1 + } } } }