github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-26 21:17:23 +00:00
Code Issues Projects Releases Wiki Activity

cancel process node if error occurs

Browse Source
This commit is contained in:
shiyan2016 2019-07-04 00:25:45 -07:00 committed by shi_yan
parent d59a603f1b
commit c329d5117d
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/scheduler/algorithm/predicates/metadata.go
View File

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