diff --git a/node/node.go b/node/node.go index 702be8f21..e7a20b091 100644 --- a/node/node.go +++ b/node/node.go @@ -185,7 +185,7 @@ func (n *NodeController) Run(ctx context.Context) error { n.statusInterval = DefaultStatusUpdateInterval } - n.chStatusUpdate = make(chan *corev1.Node) + n.chStatusUpdate = make(chan *corev1.Node, 1) n.p.NotifyNodeStatus(ctx, func(node *corev1.Node) { n.chStatusUpdate <- node })