Merge pull request #1192 from prameshj/err-handle

Handle error when calculating endpoints for NEG.
kubernetes · Jul 21, 2020 · 82122cd · 82122cd
2 parents c3026d8 + 0a01591
commit 82122cd
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/neg/syncers/transaction.go b/pkg/neg/syncers/transaction.go
@@ -163,6 +163,9 @@ 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 {
+		return fmt.Errorf("endpoints calculation error in mode %q, err: %v", s.endpointsCalculator.Mode(), err)
+	}
 	s.logStats(targetMap, "desired NEG endpoints")
 
 	// Calculate the endpoints to add and delete to transform the current state to desire state