Handle error when calculating endpoints for NEG.

kubernetes · Jul 20, 2020 · 14b4814 · 14b4814
1 parent 8934f68
commit 14b4814
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/neg/syncers/transaction.go b/pkg/neg/syncers/transaction.go
@@ -163,6 +163,10 @@ func (s *transactionSyncer) syncInternal() error {
 	s.logStats(currentMap, "after in-progress operations have completed, NEG endpoints")
 
 	targetMap, endpointPodMap, err := s.endpointsCalculator.CalculateEndpoints(ep.(*apiv1.Endpoints), currentMap)
+	if err != nil {
+		klog.Warningf("Failed to calculate endpoints for NEG key %q, Endpoints Calculator mode %s", s.NegSyncerKey.String(), s.endpointsCalculator.Mode())
+		return err
+	}
 	s.logStats(targetMap, "desired NEG endpoints")
 
 	// Calculate the endpoints to add and delete to transform the current state to desire state