Merge pull request #491 from jiaxuanzhou/nodeUpdate

k8s-ci-robot · web-flow · commit b59b7c62dedf · 2018-12-12T16:38:51.000-08:00
Update nodeInfo once node was cordoned
diff --git a/pkg/scheduler/cache/event_handlers.go b/pkg/scheduler/cache/event_handlers.go
@@ -242,7 +242,8 @@ func (sc *SchedulerCache) addNode(node *v1.Node) error {
 func isNodeInfoUpdated(oldNode, newNode *v1.Node) bool {
 	return !reflect.DeepEqual(oldNode.Status.Allocatable, newNode.Status.Allocatable) ||
 		!reflect.DeepEqual(oldNode.Spec.Taints, newNode.Spec.Taints) ||
-		!reflect.DeepEqual(oldNode.Labels, newNode.Labels)
+		!reflect.DeepEqual(oldNode.Labels, newNode.Labels) ||
+		!reflect.DeepEqual(oldNode.Spec.Unschedulable, newNode.Spec.Unschedulable)
 }
 
 // Assumes that lock is already acquired.

Original file line number	Diff line number	Diff line change
`@@ -242,7 +242,8 @@ func (sc SchedulerCache) addNode(node v1.Node) error {`
`242`	`242`	`func isNodeInfoUpdated(oldNode, newNode *v1.Node) bool {`
`243`	`243`	`return !reflect.DeepEqual(oldNode.Status.Allocatable, newNode.Status.Allocatable) \|\|`
`244`	`244`	`!reflect.DeepEqual(oldNode.Spec.Taints, newNode.Spec.Taints) \|\|`
`245`		`- !reflect.DeepEqual(oldNode.Labels, newNode.Labels)`
	`245`	`+ !reflect.DeepEqual(oldNode.Labels, newNode.Labels) \|\|`
	`246`	`+ !reflect.DeepEqual(oldNode.Spec.Unschedulable, newNode.Spec.Unschedulable)`
`246`	`247`	`}`
`247`	`248`
`248`	`249`	`// Assumes that lock is already acquired.`