Merge pull request #79774 from shiyan2016/cancel-process-node

cancel process node when error occurs
This commit is contained in:
Kubernetes Prow Robot
2019-07-09 23:02:51 -07:00
committed by GitHub

View File

@@ -397,6 +397,7 @@ func getTPMapMatchingExistingAntiAffinity(pod *v1.Pod, nodeInfoMap map[string]*s
node := nodeInfo.Node()
if node == nil {
catchError(fmt.Errorf("node %q not found", allNodeNames[i]))
cancel()
return
}
for _, existingPod := range nodeInfo.PodsWithAffinity() {
@@ -465,6 +466,7 @@ func getTPMapMatchingIncomingAffinityAntiAffinity(pod *v1.Pod, nodeInfoMap map[s
node := nodeInfo.Node()
if node == nil {
catchError(fmt.Errorf("node %q not found", allNodeNames[i]))
cancel()
return
}
nodeTopologyPairsAffinityPodsMaps := newTopologyPairsMaps()