From c329d5117d0469ab46ba071d22b0956f1e2342b3 Mon Sep 17 00:00:00 2001 From: shiyan2016 Date: Thu, 4 Jul 2019 00:25:45 -0700 Subject: [PATCH] cancel process node if error occurs --- pkg/scheduler/algorithm/predicates/metadata.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/scheduler/algorithm/predicates/metadata.go b/pkg/scheduler/algorithm/predicates/metadata.go index d1f273d015f..f0058b3fcf3 100644 --- a/pkg/scheduler/algorithm/predicates/metadata.go +++ b/pkg/scheduler/algorithm/predicates/metadata.go @@ -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()